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 |