compass.services.queues

Module for “singleton” QUERIES dictionary

Functions

get_service_queue(service_name)	Retrieve the queue for a service
initialize_service_queue(service_name)	Initialize an asyncio.Queue() for a service
tear_down_service_queue(service_name)	Remove the queue for a service