swh.scheduler.celery_backend.pika_listener module

This is the scheduler listener. It is in charge of listening to rabbitmq events (the task result) and flushes the “oneshot” tasks’ status in the scheduler backend. It’s the final step after a task is done.

The scheduler runner swh.scheduler.celery_backend.runner is the module in charge of pushing tasks in the queue.

swh.scheduler.celery_backend.pika_listener.get_listener(broker_url, queue_name, scheduler_backend)

swh.scheduler.celery_backend.pika_listener.get_on_message(scheduler_backend)

swh.scheduler.celery_backend.pika_listener.process_event(event, scheduler_backend)