nwcprovider/execution_queue.py
2024-09-07 09:09:22 +00:00

10 lines
262 B
Python

import asyncio
from typing import Any, Dict
execution_queue: asyncio.Queue[Dict[str, Any]] = asyncio.Queue()
async def enqueue(action):
future = asyncio.Future()
execution_queue.put_nowait({"action": action, "future": future})
return await future