cobald.daemon.runners.thread_runner module
- class cobald.daemon.runners.thread_runner.ThreadRunner(asyncio_loop: AbstractEventLoop)[source]
Bases:
BaseRunner
Runner for subroutines with
threading
Active payloads are not cancelled when the runner is closed. Only program termination forcefully cancels leftover payloads.
- flavour: Any = <module 'threading' from '/home/docs/.asdf/installs/python/3.11.6/lib/python3.11/threading.py'>
- async manage_payloads()[source]
Implementation of managing payloads when
run()
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,OrphanedReturn
or the raised exception must re-raised by this method.