Reset redis pipeline at end of enqueue_query (#6540)

getredash · Oct 21, 2023 · 39766a2 · 39766a2
1 parent 593b6ae
commit 39766a2
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/redash/tasks/queries/execution.py b/redash/tasks/queries/execution.py
@@ -112,6 +112,8 @@ def enqueue_query(query, data_source, user_id, is_api_key=False, scheduled_query
 
         except redis.WatchError:
             continue
+        finally:
+            pipe.reset()
 
     if not job:
         logger.error("[Manager][%s] Failed adding job for query.", query_hash)