temporalio.worker.SharedStateManager

class documentation

Base class for a shared state manager providing cross-process-safe primitives for use by activity executors.

Cross-worker use of the shared state manager is encouraged. create_from_multiprocessing provides the commonly used implementation.

Static Method	`create_from_multiprocessing`	Create a shared state manager from a multiprocessing manager.
Method	`new_event`	Create a threading.Event that can be used across processes.
Async Method	`register_heartbeater`	Register a heartbeat function.
Async Method	`unregister_heartbeater`	Unregisters a previously registered heartbeater for the task token. This should also flush any pending heartbeats.

Create a shared state manager from a multiprocessing manager.

Create a threading.Event that can be used across processes.

Parameters
task_token:`bytes`	Unique task token for the heartbeater.
heartbeat:`Callable[..., None]`	Function that should be called when the resulting sender is sent a heartbeat.

@abstractmethod

async def unregister_heartbeater(self, task_token: bytes): (source) ¶

Unregisters a previously registered heartbeater for the task token. This should also flush any pending heartbeats.