Add a store_query_status()

PostHog · Jul 25, 2024 · 8480cf3 · 8480cf3
1 parent 8edb85c
commit 8480cf3
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/posthog/clickhouse/client/execute_async.py b/posthog/clickhouse/client/execute_async.py
@@ -162,6 +162,8 @@ def execute_process_query(
         return
 
     query_status.pickup_time = datetime.datetime.now(datetime.UTC)
+    manager.store_query_status(query_status)
+
     query_status.error = True  # Assume error in case nothing below ends up working
     query_status.complete = True