Skip to content

Commit 1f91c0b

Browse files
connections: fix pipeline usage for exists command (#366)
1 parent 9ce2fd6 commit 1f91c0b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

arq/connections.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -145,7 +145,7 @@ async def enqueue_job(
145145

146146
async with self.pipeline(transaction=True) as pipe:
147147
await pipe.watch(job_key)
148-
if any(await asyncio.gather(pipe.exists(job_key), pipe.exists(result_key_prefix + job_id))):
148+
if await pipe.exists(job_key, result_key_prefix + job_id):
149149
await pipe.reset()
150150
return None
151151

0 commit comments

Comments
 (0)