swh.scheduler package

Subpackages

• swh.scheduler.api package
  • Submodules
    • swh.scheduler.api.client module
    • swh.scheduler.api.serializers module
    • swh.scheduler.api.server module
  • Module contents
• swh.scheduler.celery_backend package
  • Submodules
    • swh.scheduler.celery_backend.config module
    • swh.scheduler.celery_backend.listener module
    • swh.scheduler.celery_backend.pika_listener module
    • swh.scheduler.celery_backend.runner module
  • Module contents
• swh.scheduler.cli package
  • Submodules
    • swh.scheduler.cli.admin module
    • swh.scheduler.cli.celery_monitor module
    • swh.scheduler.cli.task module
    • swh.scheduler.cli.task_type module
    • swh.scheduler.cli.utils module
  • Module contents

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.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)

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, args={})

Get a scheduler object of class scheduler_class with arguments scheduler_args.

Parameters

• scheduler (dict) – dictionary with keys:

• cls (str) – scheduler’s class, either ‘local’ or ‘remote’

• args (dict) – dictionary with keys, default to empty.

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. –