swh.scheduler.celery_backend package

Submodules

• swh.scheduler.celery_backend.config module
  • setup_log_handler()
  • setup_queues_and_tasks()
  • on_worker_init()
  • monotonic()
  • route_for_task()
  • get_queue_stats()
  • get_queue_length()
  • get_available_slots()
  • register_task_class()
  • build_app()
  • celery_task_prerun()
• swh.scheduler.celery_backend.first_visits module
  • schedule_first_visits()
• swh.scheduler.celery_backend.pika_listener module
  • get_listener()
  • get_on_message()
  • process_event()
• swh.scheduler.celery_backend.recurrent_visits module
  • DEFAULT_POLICY_CONFIG
  • MIN_SLOTS_RATIO
  • QUEUE_FULL_BACKOFF
  • DEFAULT_NO_ORIGINS_SCHEDULED_BACKOFF
  • BACKOFF_SPLAY
  • TERMINATE
  • grab_next_visits_policy_weights()
  • splay()
  • send_visits_for_visit_type()
  • visit_scheduler_thread()
  • VisitSchedulerThreads
  • spawn_visit_scheduler_thread()
  • terminate_visit_scheduler_threads()
• swh.scheduler.celery_backend.runner module
  • write_to_backends()
  • run_ready_tasks()
  • main()
• swh.scheduler.celery_backend.utils module
  • get_loader_task_type()
  • send_to_celery()

Module contents