connections: fix pipeline usage for exists command

samuelcolvin · Nov 29, 2022 · 5794784 · 5794784
1 parent 9ce2fd6
commit 5794784
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/arq/connections.py b/arq/connections.py
@@ -145,7 +145,7 @@ async def enqueue_job(
 
         async with self.pipeline(transaction=True) as pipe:
             await pipe.watch(job_key)
-            if any(await asyncio.gather(pipe.exists(job_key), pipe.exists(result_key_prefix + job_id))):
+            if await pipe.exists(job_key, result_key_prefix + job_id):
                 await pipe.reset()
                 return None