diff options
author | Finnci <4cfinn@gmail.com> | 2019-01-22 00:53:14 +0000 |
---|---|---|
committer | Selwin Ong <selwin.ong@gmail.com> | 2019-01-22 07:53:14 +0700 |
commit | 14db0ecd264162fbd1ab894eac078ac842a935b4 (patch) | |
tree | 87ae8d0137e0f45bcbbce475b9d66970367915cf /tests/test_worker.py | |
parent | 972778d041862ee218880affccb7ef54e6cd7634 (diff) | |
download | rq-14db0ecd264162fbd1ab894eac078ac842a935b4.tar.gz |
Update/add flag for description logging (#991)
* test workers
* indent
* add docs and add option to the cli
* rename flag for cli
* logging
Diffstat (limited to 'tests/test_worker.py')
-rw-r--r-- | tests/test_worker.py | 18 |
1 files changed, 18 insertions, 0 deletions
diff --git a/tests/test_worker.py b/tests/test_worker.py index 9a18a37..b826f2b 100644 --- a/tests/test_worker.py +++ b/tests/test_worker.py @@ -816,6 +816,24 @@ class TestWorker(RQTestCase): w.perform_job(job, q) self.assertNotIn('Result is kept for 10 seconds', [c[0][0] for c in mock_logger_info.call_args_list]) + @mock.patch('rq.worker.logger.info') + def test_log_job_description_true(self, mock_logger_info): + """Check that log_job_description True causes job lifespan to be logged.""" + q = Queue() + w = Worker([q]) + job = q.enqueue(say_hello, args=('Frank',), result_ttl=10) + w.dequeue_job_and_maintain_ttl(10) + self.assertIn("Frank", mock_logger_info.call_args[0][0]) + + @mock.patch('rq.worker.logger.info') + def test_log_job_description_false(self, mock_logger_info): + """Check that log_job_description False causes job lifespan to not be logged.""" + q = Queue() + w = Worker([q], log_job_description=False) + job = q.enqueue(say_hello, args=('Frank',), result_ttl=10) + w.dequeue_job_and_maintain_ttl(10) + self.assertNotIn("Frank", mock_logger_info.call_args[0][0]) + def kill_worker(pid, double_kill): # wait for the worker to be started over on the main process |