primus.command_worker.scheduler module

Standard-library heartbeat scheduling for the portable worker core.

class primus.command_worker.scheduler.ThreadHeartbeatScheduler(shutdown_timeout: timedelta = datetime.timedelta(seconds=5))

Bases: object

Run recurring callbacks on a daemon thread with bounded shutdown.

__init__(shutdown_timeout: timedelta = datetime.timedelta(seconds=5)) → None

start(interval: timedelta, callback: Callable[[], None]) → _ThreadHeartbeatHandle