diff options
| author | glaslos <lukas.rist@bluecoat.com> | 2015-01-29 14:24:18 +0100 |
|---|---|---|
| committer | glaslos <lukas.rist@bluecoat.com> | 2015-01-29 14:24:18 +0100 |
| commit | 646f1cda223b56a779d6fdf1ea7afcdcca7443ba (patch) | |
| tree | 3cf405aeb72bfeb4e1140cccdf5da436a76bf85f /tests/test_job.py | |
| parent | 3af0e95ce5a0314fa8d95b60785e6cf2979e9d6b (diff) | |
| parent | 618270c9512da15074297c4549de5f50141cb60c (diff) | |
| download | rq-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.py | 11 |
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.""" |
