Changeset View
Changeset View
Standalone View
Standalone View
swh/scheduler/pytest_plugin.py
| Show All 37 Lines | for fname in all_dump_files: | ||||
| cursor.execute(fobj.read()) | cursor.execute(fobj.read()) | ||||
| postgresql.commit() | postgresql.commit() | ||||
| return scheduler_config | return scheduler_config | ||||
| @pytest.fixture | @pytest.fixture | ||||
| def swh_scheduler(swh_scheduler_config): | def swh_scheduler(swh_scheduler_config): | ||||
| scheduler = get_scheduler("local", swh_scheduler_config) | scheduler = get_scheduler("local", **swh_scheduler_config) | ||||
| for taskname in TASK_NAMES: | for taskname in TASK_NAMES: | ||||
| scheduler.create_task_type( | scheduler.create_task_type( | ||||
| { | { | ||||
| "type": "swh-test-{}".format(taskname), | "type": "swh-test-{}".format(taskname), | ||||
| "description": "The {} testing task".format(taskname), | "description": "The {} testing task".format(taskname), | ||||
| "backend_name": "swh.scheduler.tests.tasks.{}".format(taskname), | "backend_name": "swh.scheduler.tests.tasks.{}".format(taskname), | ||||
| "default_interval": timedelta(days=1), | "default_interval": timedelta(days=1), | ||||
| "min_interval": timedelta(hours=6), | "min_interval": timedelta(hours=6), | ||||
| ▲ Show 20 Lines • Show All 54 Lines • Show Last 20 Lines | |||||