Function worker

tests/extensions/memory/test_sqlalchemy_session.py:255–256

(content: str)

    submitted = [f"msg-{i}" for i in range(25)]

    async def worker(content: str) -> None:
        await session.add_items([{"role": "user", "content": content}])

    results = await asyncio.gather(
        *(worker(content) for content in submitted),