feat(queries): Add reject_on_worker_lost for async queries (#22898)

Add reject_on_worker_lost for async queries
PostHog · Jun 14, 2024 · e92f66b · e92f66b
1 parent 2ce1dac
commit e92f66b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/posthog/tasks/tasks.py b/posthog/tasks/tasks.py
@@ -47,6 +47,7 @@ def redis_heartbeat() -> None:
     retry_backoff_max=10,
     max_retries=3,
     expires=60 * 10,  # Do not run queries that got stuck for more than this
+    reject_on_worker_lost=True,
 )
 @limit_concurrency(90)  # Do not go above what CH can handle (max_concurrent_queries)
 @limit_concurrency(