Changeset View
Changeset View
Standalone View
Standalone View
swh/web/tests/conftest.py
| Show First 20 Lines • Show All 440 Lines • ▼ Show 20 Lines | def swh_scheduler(swh_scheduler): | ||||
| config["scheduler"] = swh_scheduler | config["scheduler"] = swh_scheduler | ||||
| # create load-git and load-hg task types | # create load-git and load-hg task types | ||||
| for task_type in TASK_TYPES.values(): | for task_type in TASK_TYPES.values(): | ||||
| swh_scheduler.create_task_type(task_type) | swh_scheduler.create_task_type(task_type) | ||||
| # create load-svn task type | # create load-svn task type | ||||
| swh_scheduler.create_task_type( | swh_scheduler.create_task_type( | ||||
| { | { | ||||
| "type": "load-svn", | "type": "load-svn", | ||||
| "description": "Update a mercurial repository", | "description": "Update a Subversion repository", | ||||
anlambert: thanks ! | |||||
| "backend_name": "swh.loader.svn.tasks.DumpMountAndLoadSvnRepository", | "backend_name": "swh.loader.svn.tasks.DumpMountAndLoadSvnRepository", | ||||
| "default_interval": timedelta(days=64), | "default_interval": timedelta(days=64), | ||||
| "min_interval": timedelta(hours=12), | "min_interval": timedelta(hours=12), | ||||
| "max_interval": timedelta(days=64), | "max_interval": timedelta(days=64), | ||||
| "backoff_factor": 2, | "backoff_factor": 2, | ||||
| "max_queue_length": None, | "max_queue_length": None, | ||||
| "num_retries": 7, | "num_retries": 7, | ||||
| "retry_delay": timedelta(hours=2), | "retry_delay": timedelta(hours=2), | ||||
| } | } | ||||
| ) | ) | ||||
| # create load-cvs task type | |||||
| swh_scheduler.create_task_type( | |||||
| { | |||||
| "type": "load-cvs", | |||||
| "description": "Update a CVS repository", | |||||
| "backend_name": "swh.loader.cvs.tasks.DumpMountAndLoadSvnRepository", | |||||
| "default_interval": timedelta(days=64), | |||||
| "min_interval": timedelta(hours=12), | |||||
| "max_interval": timedelta(days=64), | |||||
| "backoff_factor": 2, | |||||
| "max_queue_length": None, | |||||
| "num_retries": 7, | |||||
| "retry_delay": timedelta(hours=2), | |||||
| } | |||||
| ) | |||||
| # add method to add load-archive-files task type during tests | # add method to add load-archive-files task type during tests | ||||
| def add_load_archive_task_type(): | def add_load_archive_task_type(): | ||||
| swh_scheduler.create_task_type( | swh_scheduler.create_task_type( | ||||
| { | { | ||||
| "type": "load-archive-files", | "type": "load-archive-files", | ||||
| "description": "Load tarballs", | "description": "Load tarballs", | ||||
| "backend_name": "swh.loader.package.archive.tasks.LoadArchive", | "backend_name": "swh.loader.package.archive.tasks.LoadArchive", | ||||
| Show All 15 Lines | |||||
thanks !