Conditionally skips multiprocessing tests.

ICRAR · Nov 3, 2021 · 3f4ac1f · 3f4ac1f
1 parent 705a19e
commit 3f4ac1f
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/daliuge-engine/test/manager/test_dm.py b/daliuge-engine/test/manager/test_dm.py
@@ -584,6 +584,7 @@ def test_run_streaming_consumer_remotely2(self):
         self._test_runGraphInTwoNMs(g1, g2, rels, a_data, e_data, leaf_oid="E")
 
 
+@unittest.skipIf(multiprocessing.cpu_count() < 4, "Not enough threads to test multiprocessing")
 class TestDMParallel(NMTestsMixIn, unittest.TestCase):
     def _deploy_error_graph(self, **kwargs):
         sessionId = f"s{random.randint(0, 1000)}"
@@ -602,7 +603,6 @@ def _deploy_error_graph(self, **kwargs):
         dm.addGraphSpec(sessionId, g)
         dm.deploySession(sessionId, ["A"])
 
-    @unittest.skip
     def test_error_listener(self):
 
         evt = threading.Event()
@@ -617,7 +617,6 @@ def on_error(self, drop):
         self._deploy_error_graph(error_listener=listener())
         self.assertTrue(evt.wait(10), "Didn't receive errors on time")
 
-    @unittest.skip
     def test_event_listener(self):
         """Tests that user-provided event listeners work"""