pipeline calls to get dependency statuses

2020-05-13 23:12:45 -04:00 · 2020-05-13 23:12:45 -04:00 · 33e4beacf4
parent 0b528dae4b
commit 33e4beacf4
1 changed files with 5 additions and 5 deletions
--- a/rq/job.py
+++ b/rq/job.py
@ -763,11 +763,11 @@ class Job(object):
        if exclude_job_id:
            dependencies_ids.discard(exclude_job_id)

-        dependencies_statuses = [
-            connection.hget(self.key_for(key), 'status')
-            for key
-            in dependencies_ids
-        ]
+        with connection.pipeline() as pipeline:
+            for key in dependencies_ids:
+                pipeline.hget(self.key_for(key), 'status')
+
+            dependencies_statuses = pipeline.execute()

        return all(
            status.decode() == JobStatus.FINISHED