diff --git a/posthog/tasks/tasks.py b/posthog/tasks/tasks.py
index c370e70207454..a9cf873fdbd9b 100644
--- 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(