diff options
author | Pierre Mdawar <p.mdawar@gmail.com> | 2020-04-24 04:06:36 +0300 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-04-24 08:06:36 +0700 |
commit | eb92d688a8fc81ac56fb101606f8f2458460f753 (patch) | |
tree | 81bb6581d7828497d57b5318ae4960f47ff8d868 | |
parent | 0dd9ff0ec9a91e5a81cd5a30651287cad32f8ab0 (diff) | |
download | rq-eb92d688a8fc81ac56fb101606f8f2458460f753.tar.gz |
Add the queue to the Redis queues set when scheduling a job (#1238)
* Add the queue to the queues set when scheduling a job
* Fix the registry properties docstrings
-rw-r--r-- | rq/queue.py | 12 |
1 files changed, 7 insertions, 5 deletions
diff --git a/rq/queue.py b/rq/queue.py index 4316653..0aebe8f 100644 --- a/rq/queue.py +++ b/rq/queue.py @@ -192,25 +192,25 @@ class Queue(object): @property def started_job_registry(self): - """Returns this queue's FailedJobRegistry.""" + """Returns this queue's StartedJobRegistry.""" from rq.registry import StartedJobRegistry return StartedJobRegistry(queue=self, job_class=self.job_class) @property def finished_job_registry(self): - """Returns this queue's FailedJobRegistry.""" + """Returns this queue's FinishedJobRegistry.""" from rq.registry import FinishedJobRegistry return FinishedJobRegistry(queue=self) @property def deferred_job_registry(self): - """Returns this queue's FailedJobRegistry.""" + """Returns this queue's DeferredJobRegistry.""" from rq.registry import DeferredJobRegistry return DeferredJobRegistry(queue=self, job_class=self.job_class) @property def scheduled_job_registry(self): - """Returns this queue's FailedJobRegistry.""" + """Returns this queue's ScheduledJobRegistry.""" from rq.registry import ScheduledJobRegistry return ScheduledJobRegistry(queue=self, job_class=self.job_class) @@ -380,7 +380,7 @@ class Queue(object): (f, timeout, description, result_ttl, ttl, failure_ttl, depends_on, job_id, at_front, meta, args, kwargs) = Queue.parse_args(f, *args, **kwargs) - + return self.enqueue_call( func=f, args=args, kwargs=kwargs, timeout=timeout, result_ttl=result_ttl, ttl=ttl, failure_ttl=failure_ttl, @@ -401,6 +401,8 @@ class Queue(object): registry = ScheduledJobRegistry(queue=self) with self.connection.pipeline() as pipeline: + # Add Queue key set + pipeline.sadd(self.redis_queues_keys, self.key) job.save(pipeline=pipeline) registry.schedule(job, datetime, pipeline=pipeline) pipeline.execute() |