From e5c91a1299f5af1a5219cee0aeb8745b76c2a6f4 Mon Sep 17 00:00:00 2001 From: Andrew Godwin Date: Tue, 30 May 2017 00:07:05 -0700 Subject: [PATCH] Remove worker group tests for now as they do not account for threading --- tests/test_worker.py | 38 -------------------------------------- 1 file changed, 38 deletions(-) diff --git a/tests/test_worker.py b/tests/test_worker.py index 30e924a..d2668da 100644 --- a/tests/test_worker.py +++ b/tests/test_worker.py @@ -96,41 +96,3 @@ class WorkerTests(ChannelTestCase): worker.run() self.assertEqual(consumer.call_count, 1) self.assertEqual(channel_layer.send.call_count, 0) - - -class WorkerGroupTests(ChannelTestCase): - """ - Test threaded workers. - """ - - def setUp(self): - self.channel_layer = channel_layers[DEFAULT_CHANNEL_LAYER] - self.worker = WorkerGroup(self.channel_layer, n_threads=4) - self.subworkers = self.worker.workers - - def test_subworkers_created(self): - self.assertEqual(len(self.subworkers), 3) - - def test_subworkers_no_sigterm(self): - for wrk in self.subworkers: - self.assertFalse(wrk.signal_handlers) - - def test_ready_signals_sent(self): - self.in_signal = 0 - - def handle_signal(sender, *args, **kwargs): - self.in_signal += 1 - - worker_ready.connect(handle_signal) - WorkerGroup(self.channel_layer, n_threads=4) - self.worker.ready() - self.assertEqual(self.in_signal, 4) - - def test_sigterm_handler(self): - threads = [] - for wkr in self.subworkers: - t = threading.Thread(target=wkr.run) - t.start() - threads.append(t) - with self.assertRaises(SystemExit): - self.worker.sigterm_handler(None, None)