aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorDavid Hurst2017-10-14 21:40:23 -0600
committerDavid Hurst2017-10-14 21:40:23 -0600
commit9ddd1de0e8ee13bff98097890b43d33e49b5f38e (patch)
treeea8f40409a29b2ae639b85421eaa77b700a7bd47
parent990f282a9993c478dd00a4c067de32464976f8c2 (diff)
downloadeventmq-9ddd1de0e8ee13bff98097890b43d33e49b5f38e.tar.gz
eventmq-9ddd1de0e8ee13bff98097890b43d33e49b5f38e.zip
restored skipped tests
-rw-r--r--eventmq/tests/test_jobmanager.py11
-rw-r--r--eventmq/tests/test_worker.py2
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
25class TestCase(unittest.TestCase): 25class 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 @@
16import logging 16import logging
17import time 17import time
18 18
19from nose import with_setup
20
21from .. import worker 19from .. import worker
22 20
23ADDR = 'inproc://pour_the_rice_in_the_thing' 21ADDR = 'inproc://pour_the_rice_in_the_thing'