aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorDavid Hurst2017-04-18 09:09:11 -0600
committerDavid Hurst2017-04-18 09:09:11 -0600
commitc192744abba805ef07ded2a63057d42b88670ecf (patch)
treebfaa4f894242ecde477ce8d1692f30bc40d2bdf2
parent4df1344c04716fa51dc7cb2ab61ae5666804286c (diff)
downloadeventmq-c192744abba805ef07ded2a63057d42b88670ecf.tar.gz
eventmq-c192744abba805ef07ded2a63057d42b88670ecf.zip
fix send ready test
-rw-r--r--eventmq/tests/test_jobmanager.py6
1 files changed, 1 insertions, 5 deletions
diff --git a/eventmq/tests/test_jobmanager.py b/eventmq/tests/test_jobmanager.py
index 927e5f6..566c583 100644
--- a/eventmq/tests/test_jobmanager.py
+++ b/eventmq/tests/test_jobmanager.py
@@ -49,8 +49,7 @@ class TestCase(unittest.TestCase):
49 @mock.patch('eventmq.jobmanager.Sender.recv_multipart') 49 @mock.patch('eventmq.jobmanager.Sender.recv_multipart')
50 @mock.patch('eventmq.jobmanager.Poller.poll') 50 @mock.patch('eventmq.jobmanager.Poller.poll')
51 @mock.patch('eventmq.jobmanager.JobManager.maybe_send_heartbeat') 51 @mock.patch('eventmq.jobmanager.JobManager.maybe_send_heartbeat')
52 @mock.patch('eventmq.jobmanager.JobManager.send_ready') 52 def test__start_event_loop(self, maybe_send_hb_mock,
53 def test__start_event_loop(self, send_ready_mock, maybe_send_hb_mock,
54 poll_mock, sender_mock, process_msg_mock, 53 poll_mock, sender_mock, process_msg_mock,
55 pool_close_mock): 54 pool_close_mock):
56 jm = jobmanager.JobManager() 55 jm = jobmanager.JobManager()
@@ -60,9 +59,6 @@ class TestCase(unittest.TestCase):
60 59
61 jm._start_event_loop() 60 jm._start_event_loop()
62 61
63 # send int(conf.CONCURRENT_JOBS) ready messages
64 self.assertEqual(conf.CONCURRENT_JOBS, send_ready_mock.call_count)
65
66 process_msg_mock.assert_called_with( 62 process_msg_mock.assert_called_with(
67 sender_mock.return_value) 63 sender_mock.return_value)
68 64