queues/tasks.py

import asyncio


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