import asyncio, queue message_queue = asyncio.Queue()