swh.scheduler.celery_backend.pika_listener module

swh.scheduler.celery_backend.pika_listener.utcnow()[source]
swh.scheduler.celery_backend.pika_listener.get_listener(broker_url, queue_name, scheduler_backend)[source]
swh.scheduler.celery_backend.pika_listener.get_on_message(scheduler_backend)[source]
swh.scheduler.celery_backend.pika_listener.process_event(event, scheduler_backend)[source]