(q: asyncio.Queue)
| 35 | |
| 36 | |
| 37 | def empty_queue(q: asyncio.Queue) -> None: |
| 38 | while not q.empty(): |
| 39 | try: |
| 40 | q.get_nowait() |
| 41 | q.task_done() |
| 42 | except asyncio.QueueEmpty: |
| 43 | # Handle the case where the queue is already empty |
| 44 | break |
| 45 | |
| 46 | |
| 47 | class TinyAgentRequest(BaseModel): |