summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorgrayshirt <damackey@gmail.com>2020-05-10 05:35:52 -0500
committerGitHub <noreply@github.com>2020-05-10 17:35:52 +0700
commitd8dea02081bde62c39dbcb7190b9245b468e657b (patch)
tree551d89fca619c076b4394e5dcd9d4246947e94fb
parent9fb80424efe35b615d279c2a5c330e2166e32c71 (diff)
downloadrq-d8dea02081bde62c39dbcb7190b9245b468e657b.tar.gz
Parse job_id as keyword argument to delay() (#1236) (#1243)
-rw-r--r--rq/decorators.py3
1 files changed, 2 insertions, 1 deletions
diff --git a/rq/decorators.py b/rq/decorators.py
index a84289f..e8c1f37 100644
--- a/rq/decorators.py
+++ b/rq/decorators.py
@@ -51,6 +51,7 @@ class job(object): # noqa
queue = self.queue
depends_on = kwargs.pop('depends_on', None)
+ job_id = kwargs.pop('job_id', None)
at_front = kwargs.pop('at_front', False)
if not depends_on:
@@ -61,7 +62,7 @@ class job(object): # noqa
return queue.enqueue_call(f, args=args, kwargs=kwargs,
timeout=self.timeout, result_ttl=self.result_ttl,
- ttl=self.ttl, depends_on=depends_on, at_front=at_front,
+ ttl=self.ttl, depends_on=depends_on, job_id=job_id, at_front=at_front,
meta=self.meta, description=self.description, failure_ttl=self.failure_ttl)
f.delay = delay
return f