swh.scheduler.celery_backend.listener module

class swh.scheduler.celery_backend.listener.ReliableEventReceiver(channel, handlers=None, routing_key='#', node_id=None, app=None, queue_prefix='celeryev', accept=None)[source]

Bases: celery.events.receiver.EventReceiver

get_consumers(consumer, channel)[source]
process(type, event, message)[source]

Process the received event by dispatching it to the appropriate handler.

swh.scheduler.celery_backend.listener.event_monitor(app, backend)[source]