import asyncio inference_queue = asyncio.Queue() image_queue = asyncio.Queue() rag_queue = asyncio.Queue()