compass.services.queues.initialize_service_queue

initialize_service_queue(service_name)

Initialize an asyncio.Queue() for a service

Repeated calls to this function return the same queue

Parameters:

service_name (str) – Name of service to initialize queue for.

Returns:

asyncio.Queue – Queue instance for this service.