diff options
| author | Selwin Ong <selwin.ong@gmail.com> | 2015-11-28 11:26:24 +0700 |
|---|---|---|
| committer | Selwin Ong <selwin.ong@gmail.com> | 2015-11-28 11:26:24 +0700 |
| commit | 5afd1a90e5c6c695e71daa5b25dcd80779e80e75 (patch) | |
| tree | 405016badb3804f39765f6103d43ada8c9c6a165 /tests | |
| parent | 8bbd8338554091b9f5ebf68fe0413f54f781a0e7 (diff) | |
| parent | 6fc34dc6a60ced355719c6b9ab3aace4fc589046 (diff) | |
| download | rq-5afd1a90e5c6c695e71daa5b25dcd80779e80e75.tar.gz | |
Merge pull request #589 from samuelcolvin/job-started_at
add job.started_at
Diffstat (limited to 'tests')
| -rw-r--r-- | tests/test_job.py | 1 | ||||
| -rw-r--r-- | tests/test_worker.py | 19 |
2 files changed, 20 insertions, 0 deletions
diff --git a/tests/test_job.py b/tests/test_job.py index 387afeb..0845259 100644 --- a/tests/test_job.py +++ b/tests/test_job.py @@ -54,6 +54,7 @@ class TestJob(RQTestCase): # ...and nothing else self.assertIsNone(job.origin) self.assertIsNone(job.enqueued_at) + self.assertIsNone(job.started_at) self.assertIsNone(job.ended_at) self.assertIsNone(job.result) self.assertIsNone(job.exc_info) diff --git a/tests/test_worker.py b/tests/test_worker.py index 4688edc..48298ee 100644 --- a/tests/test_worker.py +++ b/tests/test_worker.py @@ -86,6 +86,25 @@ class TestWorker(RQTestCase): 'Expected at least some work done.') self.assertEqual(job.result, 'Hi there, Frank!') + def test_job_times(self): + """job times are set correctly.""" + q = Queue('foo') + w = Worker([q]) + before = utcnow() + before = before.replace(microsecond=0) + job = q.enqueue(say_hello) + self.assertIsNotNone(job.enqueued_at) + self.assertIsNone(job.started_at) + self.assertIsNone(job.ended_at) + self.assertEquals(w.work(burst=True), True, + 'Expected at least some work done.') + self.assertEquals(job.result, 'Hi there, Stranger!') + after = utcnow() + job.refresh() + self.assertTrue(before <= job.enqueued_at <= after, 'Not %s <= %s <= %s' % (before, job.enqueued_at, after)) + self.assertTrue(before <= job.started_at <= after, 'Not %s <= %s <= %s' % (before, job.started_at, after)) + self.assertTrue(before <= job.ended_at <= after, 'Not %s <= %s <= %s' % (before, job.ended_at, after)) + def test_work_is_unreadable(self): """Unreadable jobs are put on the failed queue.""" q = Queue() |