Skip to content

Commit

Permalink
use default client
Browse files Browse the repository at this point in the history
  • Loading branch information
eaypek-tfh committed Jan 20, 2025
1 parent 2358241 commit ffbd418
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 9 deletions.
2 changes: 1 addition & 1 deletion deploy/stage/common-values-iris-mpc.yaml
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
image: "ghcr.io/worldcoin/iris-mpc:4c211d131320ee81f1a214a4922ccd409bc9a6f0"
image: "ghcr.io/worldcoin/iris-mpc:982558eac4514ed755b7d7e227bf8dfde334f5ae"

environment: stage
replicaCount: 1
Expand Down
10 changes: 2 additions & 8 deletions iris-mpc/src/bin/server.rs
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,6 @@ use std::{
mem,
net::IpAddr,
panic,
process::exit,
sync::{
atomic::{AtomicBool, AtomicUsize, Ordering},
Arc, LazyLock, Mutex,
Expand Down Expand Up @@ -790,7 +789,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);

Expand All @@ -803,7 +802,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));
Expand Down Expand Up @@ -1081,7 +1080,6 @@ async fn server_main(config: Config) -> eyre::Result<()> {
let load_chunks_parallelism = config.load_chunks_parallelism;
let db_chunks_bucket_name = config.db_chunks_bucket_name.clone();
let db_chunks_folder_name = config.db_chunks_folder_name.clone();
let env = config.environment.clone();

let (tx, rx) = oneshot::channel();
background_tasks.spawn_blocking(move || {
Expand Down Expand Up @@ -1334,10 +1332,6 @@ async fn server_main(config: Config) -> eyre::Result<()> {
time_loading_into_memory,
);

if env.eq("stage") {
tracing::info!("Test environment detected, exiting");
exit(0);
}
// Clear the memory allocated by temp HashSet
serial_ids_from_db.clear();
serial_ids_from_db.shrink_to_fit();
Expand Down

0 comments on commit ffbd418

Please sign in to comment.