Changeset View
Changeset View
Standalone View
Standalone View
swh/scheduler/tests/test_fixtures.py
| Show All 18 Lines | def run(self, *, foo): | ||||
| task_has_run = True | task_has_run = True | ||||
| class FixtureTest(SchedulerTestFixture, unittest.TestCase): | class FixtureTest(SchedulerTestFixture, unittest.TestCase): | ||||
| def setUp(self): | def setUp(self): | ||||
| super().setUp() | super().setUp() | ||||
| self.add_scheduler_task_type( | self.add_scheduler_task_type( | ||||
| 'some_test_task_type', | 'some_test_task_type', | ||||
| 'swh.scheduler.tests.test_fixtures.SomeTestTask') | 'swh.scheduler.tests.test_fixtures.SomeTestTask', | ||||
| SomeTestTask, | |||||
| ) | |||||
| def test_task_run(self): | def test_task_run(self): | ||||
| self.scheduler.create_tasks([create_task_dict( | self.scheduler.create_tasks([create_task_dict( | ||||
| 'some_test_task_type', | 'some_test_task_type', | ||||
| 'oneshot', | 'oneshot', | ||||
| foo='bar', | foo='bar', | ||||
| )]) | )]) | ||||
| self.assertEqual(task_has_run, False) | self.assertEqual(task_has_run, False) | ||||
| self.run_ready_tasks() | self.run_ready_tasks() | ||||
| self.assertEqual(task_has_run, True) | self.assertEqual(task_has_run, True) | ||||