diff --git a/beat/web/utils/tests/test_scheduling.py b/beat/web/utils/tests/test_scheduling.py index e64f93109529ed3e6ce1f8382a50490daa468172..9da85506640c292407f299c7c34da5eb6ec7ad3e 100644 --- a/beat/web/utils/tests/test_scheduling.py +++ b/beat/web/utils/tests/test_scheduling.py @@ -30,6 +30,8 @@ import multiprocessing import tempfile import time +from unittest import skipIf + from django.test import TransactionTestCase from django.conf import settings from django.core.management import call_command @@ -68,6 +70,7 @@ def start_scheduler(broker_address, verbosity=0): call_command("scheduler", broker_address=broker_address, verbosity=verbosity) +@skipIf(settings.RUNNING_ON_CI, "Not runnable on the CI") class WorkerRegistration(TransactionTestCase): def setUp(self): db_worker = Worker(name="test_worker1", active=False, cores=1, memory=12) @@ -133,6 +136,7 @@ class WorkerRegistration(TransactionTestCase): # ---------------------------------------------------------- +@skipIf(settings.RUNNING_ON_CI, "Not runnable on the CI") class TestSchedulerBase(TransactionTestCase, BackendUtilitiesMixin): def __init__(self, methodName="runTest"): super(TestSchedulerBase, self).__init__(methodName) @@ -251,6 +255,7 @@ class TestSchedulerBase(TransactionTestCase, BackendUtilitiesMixin): # ---------------------------------------------------------- +@skipIf(settings.RUNNING_ON_CI, "Not runnable on the CI") class TestConnection(TestSchedulerBase): def test_worker_connection(self): self.start_scheduling() @@ -324,6 +329,7 @@ class TestConnection(TestSchedulerBase): # ---------------------------------------------------------- +@skipIf(settings.RUNNING_ON_CI, "Not runnable on the CI") class TestExecution(TestSchedulerBase): def setUp(self): super(TestExecution, self).setUp() @@ -566,6 +572,7 @@ class TestExecution(TestSchedulerBase): # ---------------------------------------------------------- +@skipIf(settings.RUNNING_ON_CI, "Not runnable on the CI") class TestCancellation(TestSchedulerBase): def setUp(self): super(TestCancellation, self).setUp() @@ -662,7 +669,6 @@ class TestCancellation(TestSchedulerBase): self.assertEqual(xp_to_finish.blocks.filter(status=Block.PROCESSING).count(), 0) def test_one_split_running(self): - self.process("user/user/single/1/single_sleep_4") def test_one_split_of_two_in_a_block_running(self):