swh.scheduler package¶
Subpackages:
Submodules:
- swh.scheduler.backend module
- swh.scheduler.backend_es module
- swh.scheduler.cli_utils module
- swh.scheduler.elasticsearch_memory module
- swh.scheduler.exc module
- swh.scheduler.interface module
- swh.scheduler.journal_client module
- swh.scheduler.model module
- swh.scheduler.pytest_plugin module
- swh.scheduler.task module
- swh.scheduler.utils module
Module contents:
-
swh.scheduler.
compute_nb_tasks_from
(num_tasks)[source]¶ - Compute and returns the tuple, number of tasks without priority,
number of tasks with priority.
- Parameters
num_tasks (int) –
- Returns
tuple number of tasks without priority (int), number of tasks with priority (int)
-
swh.scheduler.
get_scheduler
(cls: str, **kwargs) → SchedulerInterface[source]¶ Get a scheduler object of class cls with arguments **kwargs.
- Parameters
cls – scheduler’s class, either ‘local’ or ‘remote’
kwargs – arguments to pass to the class’ constructor
- Returns
local: swh.scheduler.backend.SchedulerBackend remote: swh.scheduler.api.client.RemoteScheduler
- Return type
an instance of swh.scheduler, either local or remote
- Raises
ValueError if passed an unknown storage class. –