Add 'ignore_existing_conns' to scheduler config

crates/network-scheduler/config.yml

@@ -38,4 +38,5 @@ scheduler_state_bucket: network-scheduler-state-test
 supported_worker_versions: ">=1.0.0-rc3"
 recommended_worker_versions: ">=1.0.0"
 jail_unreachable: false
+ignore_existing_conns: false
 ping_processing_threads: 16

crates/network-scheduler/src/cli.rs

@@ -61,6 +61,8 @@ pub struct Config {
     pub recommended_worker_versions: VersionReq,
     #[serde(default)]
     pub jail_unreachable: bool,
+    #[serde(default)]
+    pub ignore_existing_conns: bool,
     #[serde(default = "num_cpus::get")]
     pub ping_processing_threads: usize,
     #[serde(skip_serializing, skip_deserializing, default)]

crates/network-scheduler/src/main.rs

@@ -2,9 +2,9 @@ use clap::Parser;
 use env_logger::Env;
 use prometheus_client::registry::Registry;
 
-use sqd_network_transport::P2PTransportBuilder;
+use sqd_network_transport::{P2PTransportBuilder, SchedulerConfig};
 
-use crate::cli::Cli;
+use crate::cli::{Cli, Config};
 use crate::server::Server;
 use crate::storage::S3Storage;
 
@@ -45,8 +45,12 @@ async fn main() -> anyhow::Result<()> {
     let transport_builder = P2PTransportBuilder::from_cli(args.transport).await?;
     let contract_client: Box<dyn sqd_contract_client::Client> = transport_builder.contract_client();
     let local_peer_id = transport_builder.local_peer_id();
+    let scheduler_config = SchedulerConfig {
+        ignore_existing_conns: Config::get().ignore_existing_conns,
+        ..Default::default()
+    };
     let (incoming_messages, transport_handle) =
-        transport_builder.build_scheduler(Default::default())?;
+        transport_builder.build_scheduler(scheduler_config)?;
 
     // Get scheduling units
     let storage = S3Storage::new(local_peer_id).await;