federation: parallel sending per instance

Cargo.toml

@@ -139,7 +139,7 @@ anyhow = { version = "1.0.81", features = [
 diesel_ltree = "0.3.1"
 typed-builder = "0.18.1"
 serial_test = "2.0.0"
-tokio = { version = "1.36.0", features = ["full"] }
+tokio = { version = "1.37.0", features = ["full"] }
 regex = "1.10.3"
 once_cell = "1.19.0"
 diesel-derive-newtype = "2.1.0"

crates/federate/src/lib.rs

@@ -73,19 +73,16 @@ async fn start_stop_federation_workers(
         // create new worker
         let config = federation_config.clone();
         let stats_sender = stats_sender.clone();
-        let pool = pool.clone();
         workers.insert(
           instance.id,
           CancellableTask::spawn(WORKER_EXIT_TIMEOUT, move |stop| {
             let instance = instance.clone();
-            let req_data = config.clone().to_request_data();
+            let config = config.clone();
             let stats_sender = stats_sender.clone();
-            let pool = pool.clone();
             async move {
               InstanceWorker::init_and_loop(
                 instance,
-                req_data,
-                &mut DbPool::Pool(&pool),
+                config,
                 stop,
                 stats_sender,
               )