summaryrefslogtreecommitdiff
path: root/tests/test_job.py
diff options
context:
space:
mode:
authorglaslos <lukas.rist@bluecoat.com>2015-01-29 14:24:18 +0100
committerglaslos <lukas.rist@bluecoat.com>2015-01-29 14:24:18 +0100
commit646f1cda223b56a779d6fdf1ea7afcdcca7443ba (patch)
tree3cf405aeb72bfeb4e1140cccdf5da436a76bf85f /tests/test_job.py
parent3af0e95ce5a0314fa8d95b60785e6cf2979e9d6b (diff)
parent618270c9512da15074297c4549de5f50141cb60c (diff)
downloadrq-646f1cda223b56a779d6fdf1ea7afcdcca7443ba.tar.gz
Merge branch 'master' into ttl_tests_fixes
Conflicts: rq/queue.py
Diffstat (limited to 'tests/test_job.py')
-rw-r--r--tests/test_job.py11
1 files changed, 9 insertions, 2 deletions
diff --git a/tests/test_job.py b/tests/test_job.py
index 1684315..b9a466e 100644
--- a/tests/test_job.py
+++ b/tests/test_job.py
@@ -7,6 +7,7 @@ from datetime import datetime
from rq.compat import as_text, PY2
from rq.exceptions import NoSuchJobError, UnpickleError
from rq.job import get_current_job, Job
+from rq.registry import DeferredJobRegistry
from rq.queue import Queue
from rq.utils import utcformat
@@ -347,12 +348,18 @@ class TestJob(RQTestCase):
self.assertRaises(NoSuchJobError, Job.fetch, job.id, self.testconn)
def test_register_dependency(self):
- """Test that jobs updates the correct job dependents."""
- job = Job.create(func=say_hello)
+ """Ensure dependency registration works properly."""
+ origin = 'some_queue'
+ registry = DeferredJobRegistry(origin, self.testconn)
+
+ job = Job.create(func=say_hello, origin=origin)
job._dependency_id = 'id'
job.save()
+
+ self.assertEqual(registry.get_job_ids(), [])
job.register_dependency()
self.assertEqual(as_text(self.testconn.spop('rq:job:id:dependents')), job.id)
+ self.assertEqual(registry.get_job_ids(), [job.id])
def test_cancel(self):
"""job.cancel() deletes itself & dependents mapping from Redis."""