temporarily disable Sync proving services

Author: omerfirmak

examples/cloud.rs

@@ -75,7 +75,7 @@ struct CloudProver {
     api_key: String,
 }
 
-#[async_trait]
+#[async_trait(?Send)]
 impl ProvingService for CloudProver {
     fn is_local(&self) -> bool {
         false

examples/local.rs

@@ -51,7 +51,7 @@ impl LocalProverConfig {
 
 struct LocalProver {}
 
-#[async_trait]
+#[async_trait(?Send)]
 impl ProvingService for LocalProver {
     fn is_local(&self) -> bool {
         true

src/prover/mod.rs

@@ -60,38 +60,6 @@ where
         }
     }
 
-    pub async fn run_with_n_workers(self)
-    where
-        Backend: ProvingService + Send + Sync + 'static,
-    {
-        assert!(self.n_workers == self.coordinator_clients.len());
-        if self.proof_types.contains(&ProofType::Chunk) {
-            assert!(self.l2geth_client.is_some());
-        }
-
-        self.test_coordinator_connection().await;
-
-        let app = Router::new().route("/", get(|| async { "OK" }));
-        let addr = SocketAddr::from_str(&self.health_listener_addr)
-            .expect("Failed to parse socket address");
-        let server = axum::Server::bind(&addr).serve(app.into_make_service());
-        let health_check_server_task = tokio::spawn(server);
-
-        let mut provers = JoinSet::new();
-        let self_arc = std::sync::Arc::new(self);
-        for i in 0..self_arc.n_workers {
-            let self_clone = std::sync::Arc::clone(&self_arc);
-            provers.spawn(async move {
-                self_clone.working_loop(i).await;
-            });
-        }
-
-        tokio::select! {
-            _ = health_check_server_task => {},
-            _ = async { while provers.join_next().await.is_some() {} } => {},
-        }
-    }
-
     async fn test_coordinator_connection(&self) {
         self.coordinator_clients[0]
             .get_token(true)

src/prover/proving_service.rs

@@ -1,7 +1,7 @@
 use super::ProofType;
 use async_trait::async_trait;
 
-#[async_trait]
+#[async_trait(?Send)]
 pub trait ProvingService {
     fn is_local(&self) -> bool;
     async fn get_vks(&self, req: GetVkRequest) -> GetVkResponse;