()
| 396 | |
| 397 | def worker(session_id: str, content: str) -> None: |
| 398 | async def run() -> tuple[str, Any]: |
| 399 | session = SQLAlchemySession.from_url(session_id, url=db_url, create_tables=True) |
| 400 | barrier.wait() |
| 401 | try: |
| 402 | await asyncio.wait_for( |
| 403 | session.add_items([{"role": "user", "content": content}]), |
| 404 | timeout=5, |
| 405 | ) |
| 406 | stored = await session.get_items() |
| 407 | return ("ok", stored) |
| 408 | finally: |
| 409 | await session.engine.dispose() |
| 410 | |
| 411 | try: |
| 412 | status, payload = asyncio.run(run()) |