import asyncio

message_queue = asyncio.Queue()