Tweak batch size

ooni · Sep 4, 2024 · 523119f · 523119f
1 parent 8eda4c7
commit 523119f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/oonipipeline/src/oonipipeline/temporal/workflows/observations.py b/oonipipeline/src/oonipipeline/temporal/workflows/observations.py
@@ -99,7 +99,7 @@ async def run(self, params: ObservationsWorkflowParams) -> dict:
             batch_params = MakeObservationsFileEntryBatch(
                 file_entry_batch=batch,
                 clickhouse=params.clickhouse,
-                write_batch_size=500_000,
+                write_batch_size=1_000_000,
                 data_dir=params.data_dir,
                 bucket_date=params.bucket_date,
                 probe_cc=params.probe_cc,