- class cobald.daemon.runners.trio_runner.TrioRunner(asyncio_loop: AbstractEventLoop)
Runner for coroutines with
All active payloads are actively cancelled when the runner is closed.
- async aclose()
Shut down this runner
- flavour: Any = <module 'trio' from '/home/docs/checkouts/readthedocs.org/user_builds/cobald/envs/latest/lib/python3.11/site-packages/trio/__init__.py'>
- async manage_payloads()
Implementation of managing payloads when
This method must continuously execute payloads sent to the runner. It may only return when
stop()is called or if any orphaned payload return or raise. In the latter case,
OrphanedReturnor the raised exception must re-raised by this method.
- async ready()
Wait until the runner is ready to accept payloads
- register_payload(payload: Callable[, Awaitable])
payloadfor background execution in a threadsafe manner
payloadas an orphaned background task as soon as possible. It is an error for
payloadto return or raise anything without handling it.