diff options
| author | David Hurst | 2017-10-14 21:40:23 -0600 |
|---|---|---|
| committer | David Hurst | 2017-10-14 21:40:23 -0600 |
| commit | 9ddd1de0e8ee13bff98097890b43d33e49b5f38e (patch) | |
| tree | ea8f40409a29b2ae639b85421eaa77b700a7bd47 | |
| parent | 990f282a9993c478dd00a4c067de32464976f8c2 (diff) | |
| download | eventmq-9ddd1de0e8ee13bff98097890b43d33e49b5f38e.tar.gz eventmq-9ddd1de0e8ee13bff98097890b43d33e49b5f38e.zip | |
restored skipped tests
| -rw-r--r-- | eventmq/tests/test_jobmanager.py | 11 | ||||
| -rw-r--r-- | eventmq/tests/test_worker.py | 2 |
2 files changed, 0 insertions, 13 deletions
diff --git a/eventmq/tests/test_jobmanager.py b/eventmq/tests/test_jobmanager.py index 963d135..777e69c 100644 --- a/eventmq/tests/test_jobmanager.py +++ b/eventmq/tests/test_jobmanager.py | |||
| @@ -23,7 +23,6 @@ ADDR = 'inproc://pour_the_rice_in_the_thing' | |||
| 23 | 23 | ||
| 24 | 24 | ||
| 25 | class TestCase(unittest.TestCase): | 25 | class TestCase(unittest.TestCase): |
| 26 | @unittest.skip('temporarily') | ||
| 27 | def test__setup(self): | 26 | def test__setup(self): |
| 28 | jm = jobmanager.JobManager(name='RuckusBringer') | 27 | jm = jobmanager.JobManager(name='RuckusBringer') |
| 29 | self.assertEqual(jm.name, 'RuckusBringer') | 28 | self.assertEqual(jm.name, 'RuckusBringer') |
| @@ -32,7 +31,6 @@ class TestCase(unittest.TestCase): | |||
| 32 | self.assertEqual(jm.status, constants.STATUS.ready) | 31 | self.assertEqual(jm.status, constants.STATUS.ready) |
| 33 | 32 | ||
| 34 | # EMQP Tests | 33 | # EMQP Tests |
| 35 | @unittest.skip('temporarily') | ||
| 36 | def test_reset(self): | 34 | def test_reset(self): |
| 37 | jm = jobmanager.JobManager() | 35 | jm = jobmanager.JobManager() |
| 38 | 36 | ||
| @@ -40,7 +38,6 @@ class TestCase(unittest.TestCase): | |||
| 40 | self.assertEqual(jm.status, constants.STATUS.ready) | 38 | self.assertEqual(jm.status, constants.STATUS.ready) |
| 41 | 39 | ||
| 42 | @mock.patch('eventmq.jobmanager.sendmsg') | 40 | @mock.patch('eventmq.jobmanager.sendmsg') |
| 43 | @unittest.skip('temporarily') | ||
| 44 | def test_send_ready(self, sndmsg_mock): | 41 | def test_send_ready(self, sndmsg_mock): |
| 45 | jm = jobmanager.JobManager() | 42 | jm = jobmanager.JobManager() |
| 46 | jm.send_ready() | 43 | jm.send_ready() |
| @@ -52,7 +49,6 @@ class TestCase(unittest.TestCase): | |||
| 52 | @mock.patch('eventmq.jobmanager.Sender.recv_multipart') | 49 | @mock.patch('eventmq.jobmanager.Sender.recv_multipart') |
| 53 | @mock.patch('eventmq.jobmanager.Poller.poll') | 50 | @mock.patch('eventmq.jobmanager.Poller.poll') |
| 54 | @mock.patch('eventmq.jobmanager.JobManager.maybe_send_heartbeat') | 51 | @mock.patch('eventmq.jobmanager.JobManager.maybe_send_heartbeat') |
| 55 | @unittest.skip('temporarily') | ||
| 56 | def test__start_event_loop(self, maybe_send_hb_mock, | 52 | def test__start_event_loop(self, maybe_send_hb_mock, |
| 57 | poll_mock, sender_mock, process_msg_mock, | 53 | poll_mock, sender_mock, process_msg_mock, |
| 58 | pool_close_mock): | 54 | pool_close_mock): |
| @@ -71,7 +67,6 @@ class TestCase(unittest.TestCase): | |||
| 71 | jm.should_reset = True | 67 | jm.should_reset = True |
| 72 | jm._start_event_loop() | 68 | jm._start_event_loop() |
| 73 | 69 | ||
| 74 | @unittest.skip('temporarily') | ||
| 75 | def test_on_request(self): | 70 | def test_on_request(self): |
| 76 | _msgid = 'aaa0j8-ac40jf0-04tjv' | 71 | _msgid = 'aaa0j8-ac40jf0-04tjv' |
| 77 | _msg = ['a', 'b', '["run", {"a": 1}]'] | 72 | _msg = ['a', 'b', '["run", {"a": 1}]'] |
| @@ -80,7 +75,6 @@ class TestCase(unittest.TestCase): | |||
| 80 | 75 | ||
| 81 | jm.on_request(_msgid, _msg) | 76 | jm.on_request(_msgid, _msg) |
| 82 | 77 | ||
| 83 | @unittest.skip('temporarily') | ||
| 84 | def test_on_request_with_timeout(self): | 78 | def test_on_request_with_timeout(self): |
| 85 | timeout = 3 | 79 | timeout = 3 |
| 86 | _msgid = 'aaa0j8-ac40jf0-04tjv' | 80 | _msgid = 'aaa0j8-ac40jf0-04tjv' |
| @@ -90,7 +84,6 @@ class TestCase(unittest.TestCase): | |||
| 90 | 84 | ||
| 91 | jm.on_request(_msgid, _msg) | 85 | jm.on_request(_msgid, _msg) |
| 92 | 86 | ||
| 93 | @unittest.skip('temporarily') | ||
| 94 | def test_on_request_with_timeout_and_reply(self): | 87 | def test_on_request_with_timeout_and_reply(self): |
| 95 | timeout = 3 | 88 | timeout = 3 |
| 96 | _msgid = 'aaa0j8-ac40jf0-04tjv' | 89 | _msgid = 'aaa0j8-ac40jf0-04tjv' |
| @@ -104,7 +97,6 @@ class TestCase(unittest.TestCase): | |||
| 104 | 97 | ||
| 105 | @mock.patch('eventmq.jobmanager.sendmsg') | 98 | @mock.patch('eventmq.jobmanager.sendmsg') |
| 106 | @mock.patch('zmq.Socket.unbind') | 99 | @mock.patch('zmq.Socket.unbind') |
| 107 | @unittest.skip('temporarily') | ||
| 108 | def test_on_disconnect(self, socket_mock, sendmsg_mock): | 100 | def test_on_disconnect(self, socket_mock, sendmsg_mock): |
| 109 | msgid = 'goog8l-uitty40-007b' | 101 | msgid = 'goog8l-uitty40-007b' |
| 110 | msg = ['a', 'b', 'whatever'] | 102 | msg = ['a', 'b', 'whatever'] |
| @@ -118,7 +110,6 @@ class TestCase(unittest.TestCase): | |||
| 118 | 110 | ||
| 119 | # Other Tests | 111 | # Other Tests |
| 120 | @mock.patch('eventmq.jobmanager.import_settings') | 112 | @mock.patch('eventmq.jobmanager.import_settings') |
| 121 | @unittest.skip('temporarily') | ||
| 122 | def test_sighup_handler(self, import_settings_mock): | 113 | def test_sighup_handler(self, import_settings_mock): |
| 123 | jm = jobmanager.JobManager() | 114 | jm = jobmanager.JobManager() |
| 124 | 115 | ||
| @@ -131,7 +122,6 @@ class TestCase(unittest.TestCase): | |||
| 131 | import_settings_mock.assert_called_with(section='jobmanager') | 122 | import_settings_mock.assert_called_with(section='jobmanager') |
| 132 | 123 | ||
| 133 | @mock.patch('eventmq.jobmanager.sendmsg') | 124 | @mock.patch('eventmq.jobmanager.sendmsg') |
| 134 | @unittest.skip('temporarily') | ||
| 135 | def test_sigterm_handler(self, sendmsg_mock): | 125 | def test_sigterm_handler(self, sendmsg_mock): |
| 136 | jm = jobmanager.JobManager() | 126 | jm = jobmanager.JobManager() |
| 137 | 127 | ||
| @@ -143,7 +133,6 @@ class TestCase(unittest.TestCase): | |||
| 143 | 133 | ||
| 144 | @mock.patch('eventmq.jobmanager.JobManager.start') | 134 | @mock.patch('eventmq.jobmanager.JobManager.start') |
| 145 | @mock.patch('eventmq.jobmanager.import_settings') | 135 | @mock.patch('eventmq.jobmanager.import_settings') |
| 146 | @unittest.skip('temporarily') | ||
| 147 | def test_jobmanager_main(self, import_settings_mock, start_mock): | 136 | def test_jobmanager_main(self, import_settings_mock, start_mock): |
| 148 | jm = jobmanager.JobManager() | 137 | jm = jobmanager.JobManager() |
| 149 | 138 | ||
diff --git a/eventmq/tests/test_worker.py b/eventmq/tests/test_worker.py index 7a53c38..5e72f39 100644 --- a/eventmq/tests/test_worker.py +++ b/eventmq/tests/test_worker.py | |||
| @@ -16,8 +16,6 @@ | |||
| 16 | import logging | 16 | import logging |
| 17 | import time | 17 | import time |
| 18 | 18 | ||
| 19 | from nose import with_setup | ||
| 20 | |||
| 21 | from .. import worker | 19 | from .. import worker |
| 22 | 20 | ||
| 23 | ADDR = 'inproc://pour_the_rice_in_the_thing' | 21 | ADDR = 'inproc://pour_the_rice_in_the_thing' |