diff --git a/deploy/stage/smpcv2-0-stage/values-iris-mpc.yaml b/deploy/stage/smpcv2-0-stage/values-iris-mpc.yaml index cbf84a9ae..8333ed59a 100644 --- a/deploy/stage/smpcv2-0-stage/values-iris-mpc.yaml +++ b/deploy/stage/smpcv2-0-stage/values-iris-mpc.yaml @@ -78,7 +78,7 @@ env: value: "even_odd_binary_output_16k" - name: SMPC__LOAD_CHUNKS_PARALLELISM - value: "128" + value: "64" - name: SMPC__CLEAR_DB_BEFORE_INIT value: "true" diff --git a/deploy/stage/smpcv2-1-stage/values-iris-mpc.yaml b/deploy/stage/smpcv2-1-stage/values-iris-mpc.yaml index ea2b565a3..5e0b7761d 100644 --- a/deploy/stage/smpcv2-1-stage/values-iris-mpc.yaml +++ b/deploy/stage/smpcv2-1-stage/values-iris-mpc.yaml @@ -78,7 +78,7 @@ env: value: "even_odd_binary_output_16k" - name: SMPC__LOAD_CHUNKS_PARALLELISM - value: "128" + value: "64" - name: SMPC__CLEAR_DB_BEFORE_INIT value: "true" diff --git a/deploy/stage/smpcv2-2-stage/values-iris-mpc.yaml b/deploy/stage/smpcv2-2-stage/values-iris-mpc.yaml index f1e9dab74..9e3fe840e 100644 --- a/deploy/stage/smpcv2-2-stage/values-iris-mpc.yaml +++ b/deploy/stage/smpcv2-2-stage/values-iris-mpc.yaml @@ -78,7 +78,7 @@ env: value: "even_odd_binary_output_16k" - name: SMPC__LOAD_CHUNKS_PARALLELISM - value: "128" + value: "64" - name: SMPC__CLEAR_DB_BEFORE_INIT value: "true" diff --git a/iris-mpc/src/bin/server.rs b/iris-mpc/src/bin/server.rs index fe79ab323..cbcfa49ce 100644 --- a/iris-mpc/src/bin/server.rs +++ b/iris-mpc/src/bin/server.rs @@ -735,7 +735,7 @@ async fn resolve_export_bucket_ips(host: String) -> eyre::Result> { let resolver = TokioAsyncResolver::tokio(ResolverConfig::default(), resolver_opts); loop { // Check if we've collected enough unique IPs - if all_ips.len() >= 30 { + if all_ips.len() >= 4 { break; } match resolver.lookup_ip(&host).await { @@ -790,7 +790,7 @@ async fn server_main(config: Config) -> eyre::Result<()> { // Increase S3 retries to 5 let static_resolver = StaticResolver::new(db_chunks_bucket_ips.await?); - let _http_client = HyperClientBuilder::new() + let http_client = HyperClientBuilder::new() .crypto_mode(CryptoMode::Ring) .build_with_resolver(static_resolver); @@ -803,7 +803,7 @@ async fn server_main(config: Config) -> eyre::Result<()> { // disable stalled stream protection to avoid panics during s3 import .stalled_stream_protection(StalledStreamProtectionConfig::disabled()) .retry_config(retry_config) - // .http_client(http_client) + .http_client(http_client) .build(); let s3_client = Arc::new(S3Client::from_conf(s3_config));