diff options
| author | Ivan Piskunov <van-ess0@mail.ru> | 2019-10-17 04:35:51 +0300 |
|---|---|---|
| committer | Selwin Ong <selwin.ong@gmail.com> | 2019-10-17 08:35:51 +0700 |
| commit | cfc02816ea9be897eac2ddd4afc794ef548b4b4b (patch) | |
| tree | 7a172e45abffb4073c0046dddd17b6fa35b882a1 | |
| parent | e43bce4467c3e1800d75d9cedf75ab6e7e01fe8c (diff) | |
| download | rq-cfc02816ea9be897eac2ddd4afc794ef548b4b4b.tar.gz | |
Fix dependent jobs enqueueing (#1145)
If Queue was subclassed and enqueue_job changed, these changes should affect on dependent jobs' enqueueing too.
| -rw-r--r-- | rq/queue.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/rq/queue.py b/rq/queue.py index 64280de..e68dae0 100644 --- a/rq/queue.py +++ b/rq/queue.py @@ -398,7 +398,7 @@ class Queue(object): if dependent.origin == self.name: self.enqueue_job(dependent, pipeline=pipe) else: - queue = Queue(name=dependent.origin, connection=self.connection) + queue = self.__class__(name=dependent.origin, connection=self.connection) queue.enqueue_job(dependent, pipeline=pipe) pipe.delete(dependents_key) |