diff options
| author | grayshirt <damackey@gmail.com> | 2020-05-10 05:35:52 -0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-05-10 17:35:52 +0700 |
| commit | d8dea02081bde62c39dbcb7190b9245b468e657b (patch) | |
| tree | 551d89fca619c076b4394e5dcd9d4246947e94fb | |
| parent | 9fb80424efe35b615d279c2a5c330e2166e32c71 (diff) | |
| download | rq-d8dea02081bde62c39dbcb7190b9245b468e657b.tar.gz | |
Parse job_id as keyword argument to delay() (#1236) (#1243)
| -rw-r--r-- | rq/decorators.py | 3 |
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 |
