Pass pipeline to push_job_id from enqueue_job

8 years ago · f3f61bbc15
parent 20e258f610
commit f3f61bbc15
1 changed files with 3 additions and 3 deletions
--- a/rq/queue.py
+++ b/rq/queue.py
@ -290,12 +290,12 @@ class Queue(object):
            job.timeout = self.DEFAULT_TIMEOUT
        job.save(pipeline=pipe)

+        if self._async:
+            self.push_job_id(job.id, pipeline=pipe, at_front=at_front)
+
        if pipeline is None:
            pipe.execute()

-        if self._async:
-            self.push_job_id(job.id, at_front=at_front)
-
        return job

    def enqueue_dependents(self, job, pipeline=None):