summaryrefslogtreecommitdiff
path: root/tests/test_worker.py
diff options
context:
space:
mode:
authorFinnci <4cfinn@gmail.com>2019-01-22 00:53:14 +0000
committerSelwin Ong <selwin.ong@gmail.com>2019-01-22 07:53:14 +0700
commit14db0ecd264162fbd1ab894eac078ac842a935b4 (patch)
tree87ae8d0137e0f45bcbbce475b9d66970367915cf /tests/test_worker.py
parent972778d041862ee218880affccb7ef54e6cd7634 (diff)
downloadrq-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.py18
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