Re-enable optimize table call

ooni · Apr 25, 2024 · 1035bd3 · 1035bd3
1 parent f7f463a
commit 1035bd3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/oonipipeline/src/oonipipeline/temporal/workflows.py b/oonipipeline/src/oonipipeline/temporal/workflows.py
@@ -90,7 +90,8 @@ class ObservationsWorkflowParams:
 class ObservationsWorkflow:
     @workflow.run
     async def run(self, params: ObservationsWorkflowParams) -> dict:
-        # optimize_all_tables(params.clickhouse)
+        # TODO(art): wrap this a coroutine call
+        optimize_all_tables(params.clickhouse)
 
         workflow_id = workflow.info().workflow_id