Changeset View
Changeset View
Standalone View
Standalone View
swh/scheduler/tests/updater/test_writer.py
| Show First 20 Lines • Show All 46 Lines • ▼ Show 20 Lines | class UpdaterWriterTest(UpdaterTestUtil, CommonSchedulerTest, | ||||
| unittest.TestCase): | unittest.TestCase): | ||||
| def setUp(self): | def setUp(self): | ||||
| super().setUp() | super().setUp() | ||||
| config = { | config = { | ||||
| 'scheduler': { | 'scheduler': { | ||||
| 'cls': 'local', | 'cls': 'local', | ||||
| 'args': { | 'args': { | ||||
| 'scheduling_db': 'dbname=softwareheritage-scheduler-test', | 'db': 'dbname=softwareheritage-scheduler-test', | ||||
| }, | }, | ||||
| }, | }, | ||||
| 'scheduler_updater': { | 'scheduler_updater': { | ||||
| 'scheduling_updater_db': | 'cls': 'local', | ||||
| 'args': { | |||||
| 'db': | |||||
| 'dbname=softwareheritage-scheduler-updater-test', | 'dbname=softwareheritage-scheduler-updater-test', | ||||
| 'cache_read_limit': 5, | 'cache_read_limit': 5, | ||||
| }, | }, | ||||
| }, | |||||
| 'updater_writer': { | |||||
| 'pause': 0.1, | 'pause': 0.1, | ||||
| 'verbose': False, | 'verbose': False, | ||||
| }, | |||||
| } | } | ||||
| self.writer = UpdaterWriter(**config) | self.writer = UpdaterWriter(**config) | ||||
| self.scheduler_backend = self.writer.scheduler_backend | self.scheduler_backend = self.writer.scheduler_backend | ||||
| self.scheduler_updater_backend = self.writer.scheduler_updater_backend | self.scheduler_updater_backend = self.writer.scheduler_updater_backend | ||||
| def tearDown(self): | |||||
| self.scheduler_backend.close_connection() | |||||
| self.scheduler_updater_backend.close_connection() | |||||
| super().tearDown() | |||||
| def test_run_ko(self): | def test_run_ko(self): | ||||
| """Only git tasks are supported for now, other types are dismissed. | """Only git tasks are supported for now, other types are dismissed. | ||||
| """ | """ | ||||
| ready_events = [ | ready_events = [ | ||||
| SWHEvent( | SWHEvent( | ||||
| self._make_simple_event(event_type, 'origin-%s' % i, | self._make_simple_event(event_type, 'origin-%s' % i, | ||||
| 'svn')) | 'svn')) | ||||
| ▲ Show 20 Lines • Show All 76 Lines • Show Last 20 Lines | |||||