Fix redis pipeline created and not used (#374)

python-arq · Dec 14, 2022 · e6ff090 · e6ff090
1 parent 430df07
commit e6ff090
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/arq/jobs.py b/arq/jobs.py
@@ -102,9 +102,10 @@ async def result(
             poll_delay = pole_delay
 
         async for delay in poll(poll_delay):
-            async with self._redis.pipeline(transaction=True):
-                v = await self._redis.get(result_key_prefix + self.job_id)
-                s = await self._redis.zscore(self._queue_name, self.job_id)
+            async with self._redis.pipeline(transaction=True) as tr:
+                tr.get(result_key_prefix + self.job_id)  # type: ignore[unused-coroutine]
+                tr.zscore(self._queue_name, self.job_id)  # type: ignore[unused-coroutine]
+                v, s = await tr.execute()
 
             if v:
                 info = deserialize_result(v, deserializer=self._deserializer)