diff options
| -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) |