temporalio.worker._activity._MultiprocessingSharedStateManager

class documentation

class _MultiprocessingSharedStateManager(SharedStateManager): (source)

Undocumented

Method	`__init__`	Undocumented
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.
Method	`_heartbeat_processor`	Undocumented
Instance Variable	`_heartbeat_completions`	Undocumented
Instance Variable	`_heartbeat_queue`	Undocumented
Instance Variable	`_heartbeats`	Undocumented
Instance Variable	`_mgr`	Undocumented
Instance Variable	`_queue_poller_executor`	Undocumented

Static Method create_from_multiprocessing Create a shared state manager from a multiprocessing manager.

def __init__(self, mgr: multiprocessing.managers.SyncManager, queue_poller_executor: concurrent.futures.Executor): (source) ¶

Undocumented

def new_event(self) -> threading.Event: (source) ¶

overrides temporalio.worker.SharedStateManager.new_event

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

async def register_heartbeater(self, task_token: bytes, heartbeat: Callable[..., None]) -> SharedHeartbeatSender: (source) ¶

overrides temporalio.worker.SharedStateManager.register_heartbeater

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.
Returns
`SharedHeartbeatSender`	A sender that can be pickled for use in another process.

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

overrides temporalio.worker.SharedStateManager.unregister_heartbeater

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

def _heartbeat_processor(self): (source) ¶

Undocumented

_heartbeat_completions: dict[bytes, Callable] = (source) ¶

Undocumented

_heartbeat_queue: queue.Queue[tuple[bytes, Sequence[Any]]] = (source) ¶

Undocumented

_heartbeats: dict[bytes, Callable[..., None]] = (source) ¶

Undocumented

Undocumented

Undocumented