Removed @resolve_connection from job decorator.

-- resolve_connection already presence inside Queue __init__.
main
msoedov 11 years ago
parent dd994142b3
commit e76020d894

@ -1,6 +1,5 @@
from functools import wraps from functools import wraps
from .queue import Queue from .queue import Queue
from .connections import resolve_connection
from .worker import DEFAULT_RESULT_TTL from .worker import DEFAULT_RESULT_TTL
from rq.compat import string_types from rq.compat import string_types
@ -28,7 +27,7 @@ class job(object):
@wraps(f) @wraps(f)
def delay(*args, **kwargs): def delay(*args, **kwargs):
if isinstance(self.queue, string_types): if isinstance(self.queue, string_types):
queue = Queue(name=self.queue, connection=resolve_connection(self.connection)) queue = Queue(name=self.queue, connection=self.connection)
else: else:
queue = self.queue queue = self.queue
if 'depends_on' in kwargs: if 'depends_on' in kwargs:

@ -73,7 +73,7 @@ class TestDecorator(RQTestCase):
self.assertEqual(bar_job._dependency_id, foo_job.id) self.assertEqual(bar_job._dependency_id, foo_job.id)
@mock.patch('rq.decorators.resolve_connection') @mock.patch('rq.queue.resolve_connection')
def test_decorator_connection_laziness(self, resolve_connection): def test_decorator_connection_laziness(self, resolve_connection):
"""Ensure that job decorator resolve connection in `lazy` way """ """Ensure that job decorator resolve connection in `lazy` way """

Loading…
Cancel
Save