temporalio.worker._activity._MultiprocessingSharedHeartbeatSender

class documentation

class _MultiprocessingSharedHeartbeatSender(SharedHeartbeatSender): (source)

Constructor: _MultiprocessingSharedHeartbeatSender(heartbeat_queue)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method send_heartbeat Send a heartbeat for the given task token and details.
Instance Variable _heartbeat_queue Undocumented
def __init__(self, heartbeat_queue: queue.Queue[tuple[bytes, Sequence[Any]]]): (source)

Undocumented

def send_heartbeat(self, task_token: bytes, *details: Any): (source)
overrides temporalio.worker.SharedHeartbeatSender.send_heartbeat

Send a heartbeat for the given task token and details.

_heartbeat_queue = (source)

Undocumented