Revisions

* Rename `dependent_jobs` to `jobs_to_enqueue` in queue.py
* Rename `dependencies_job_ids` to `dependency_ids`.
* Remove `as_text` (no more python2 support). Use `bytes.decode`
main
Thomas Matecki 5 years ago
parent c679c1af2f
commit 0672cd00c6

@ -13,9 +13,9 @@ from rq.compat import as_text, decode_redis_hash, string_types, text_type
from .connections import resolve_connection from .connections import resolve_connection
from .exceptions import NoSuchJobError from .exceptions import NoSuchJobError
from .local import LocalStack from .local import LocalStack
from .serializers import resolve_serializer
from .utils import (enum, import_attribute, parse_timeout, str_to_date, from .utils import (enum, import_attribute, parse_timeout, str_to_date,
utcformat, utcnow) utcformat, utcnow)
from .serializers import resolve_serializer
try: try:
import cPickle as pickle import cPickle as pickle
@ -736,9 +736,9 @@ class Job(object):
connection.sadd(self.dependencies_key, dependency_id) connection.sadd(self.dependencies_key, dependency_id)
@property @property
def dependencies_job_ids(self): def dependency_ids(self):
dependencies = self.connection.smembers(self.dependencies_key) dependencies = self.connection.smembers(self.dependencies_key)
return [Job.key_for(as_text(_id)) return [Job.key_for(_id.decode())
for _id in dependencies] for _id in dependencies]
def dependencies_are_met(self, exclude_job_id=None, pipeline=None): def dependencies_are_met(self, exclude_job_id=None, pipeline=None):
@ -755,7 +755,7 @@ class Job(object):
pipe = pipeline if pipeline is not None else self.connection pipe = pipeline if pipeline is not None else self.connection
if pipeline is not None: if pipeline is not None:
pipe.watch(*self.dependencies_job_ids) pipe.watch(*self.dependency_ids)
sort_by = self.redis_job_namespace_prefix + '*->ended_at' sort_by = self.redis_job_namespace_prefix + '*->ended_at'
get_fields = ( get_fields = (

@ -463,7 +463,7 @@ class Queue(object):
dependent_job_ids = [as_text(_id) dependent_job_ids = [as_text(_id)
for _id in pipe.smembers(dependents_key)] for _id in pipe.smembers(dependents_key)]
dependent_jobs = [ jobs_to_enqueue = [
dependent_job for dependent_job dependent_job for dependent_job
in self.job_class.fetch_many( in self.job_class.fetch_many(
dependent_job_ids, dependent_job_ids,
@ -476,7 +476,7 @@ class Queue(object):
pipe.multi() pipe.multi()
for dependent in dependent_jobs: for dependent in jobs_to_enqueue:
registry = DeferredJobRegistry(dependent.origin, registry = DeferredJobRegistry(dependent.origin,
self.connection, self.connection,
job_class=self.job_class) job_class=self.job_class)

Loading…
Cancel
Save