We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9ce2fd6 commit 1f91c0bCopy full SHA for 1f91c0b
1 file changed
arq/connections.py
@@ -145,7 +145,7 @@ async def enqueue_job(
145
146
async with self.pipeline(transaction=True) as pipe:
147
await pipe.watch(job_key)
148
- 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):
149
await pipe.reset()
150
return None
151
0 commit comments