Function do_work

tests/execution/test_client_server.py:330–332

()

    """Subprocess that writes to the store."""

    async def do_work() -> None:
        # This should auto-delegate to HTTP client in subprocess
        await store.enqueue_rollout(input={"origin": "algo-subprocess"})

    asyncio.run(do_work())