From 3bcdd2299f88c51566df62ea1c4c6e409a9fe0d9 Mon Sep 17 00:00:00 2001
From: Dominik Werder <dominik.werder@gmail.com>
Date: Thu, 15 May 2025 15:24:08 +0200
Subject: [PATCH] Increase connection count

---
 scywr/src/session.rs | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/scywr/src/session.rs b/scywr/src/session.rs
index 52406f3..768cc18 100644
--- a/scywr/src/session.rs
+++ b/scywr/src/session.rs
@@ -31,12 +31,13 @@ pub async fn create_session_no_ks(scyconf: &ScyllaIngestConfig) -> Result<Arc<Se
         .build()
         .into_handle();
     let port_range: RangeInclusive<u16> = 32000u16..=36000u16;
-    let _port_range = ShardAwarePortRange::new(port_range).unwrap();
+    let port_range = ShardAwarePortRange::new(port_range).unwrap();
+    let _ = port_range;
     let scy = GenericSessionBuilder::new()
         // .disallow_shard_aware_port(true)
         // .shard_aware_local_port_range(port_range)
         // .pool_size(PoolSize::default())
-        .pool_size(PoolSize::PerHost(NonZero::new(1).unwrap()))
+        .pool_size(PoolSize::PerHost(NonZero::new(4).unwrap()))
         .known_nodes(scyconf.hosts())
         .default_execution_profile_handle(profile)
         .write_coalescing(true)