fix load summary

worldcoin · Jan 24, 2025 · c813c1d · c813c1d
1 parent afc96f2
commit c813c1d
Show file tree

Hide file tree

Showing 5 changed files with 6 additions and 4 deletions.
diff --git a/deploy/stage/common-values-iris-mpc.yaml b/deploy/stage/common-values-iris-mpc.yaml
@@ -1,4 +1,4 @@
-image: "ghcr.io/worldcoin/iris-mpc:dc77f753b0b19d9c672ebe70440158f58e213467"
+image: "ghcr.io/worldcoin/iris-mpc:4065a7f06f7c3482417f387542bf76fbd7bae1f5"
 
 environment: stage
 replicaCount: 1

diff --git a/deploy/stage/smpcv2-0-stage/values-iris-mpc.yaml b/deploy/stage/smpcv2-0-stage/values-iris-mpc.yaml
@@ -30,7 +30,7 @@ env:
     value: "true"
 
   - name: SMPC__DATABASE__LOAD_PARALLELISM
-    value: "1"
+    value: "8"
 
   - name: SMPC__AWS__REGION
     value: "eu-north-1"

diff --git a/deploy/stage/smpcv2-1-stage/values-iris-mpc.yaml b/deploy/stage/smpcv2-1-stage/values-iris-mpc.yaml
@@ -30,7 +30,7 @@ env:
     value: "true"
 
   - name: SMPC__DATABASE__LOAD_PARALLELISM
-    value: "1"
+    value: "8"
 
   - name: SMPC__AWS__REGION
     value: "eu-north-1"

diff --git a/deploy/stage/smpcv2-2-stage/values-iris-mpc.yaml b/deploy/stage/smpcv2-2-stage/values-iris-mpc.yaml
@@ -30,7 +30,7 @@ env:
     value: "true"
 
   - name: SMPC__DATABASE__LOAD_PARALLELISM
-    value: "1"
+    value: "8"
 
   - name: SMPC__AWS__REGION
     value: "eu-north-1"

diff --git a/iris-mpc/src/bin/server.rs b/iris-mpc/src/bin/server.rs
@@ -1238,6 +1238,7 @@ async fn server_main(config: Config) -> eyre::Result<()> {
                                     elapsed,
                                     load_chunks_parallelism
                                 );
+                                load_summary_ts = Instant::now();
                             }
 
                             let min_last_modified_at = last_snapshot_details.timestamp
@@ -1285,6 +1286,7 @@ async fn server_main(config: Config) -> eyre::Result<()> {
 
                             time_waiting_for_stream = Duration::from_secs(0);
                             time_loading_into_memory = Duration::from_secs(0);
+                            load_summary_ts = Instant::now();
                             while let Some(iris) = rx.recv().await {
                                 time_waiting_for_stream += load_summary_ts.elapsed();
                                 load_summary_ts = Instant::now();