temporalio.worker._activity

module documentation
(source)

Activity worker.

Variable logger Undocumented
Class _ActivityInboundImpl Undocumented
Class _ActivityOutboundImpl Undocumented
Class _ActivityWorker Undocumented
Class _MultiprocessingSharedHeartbeatSender Undocumented
Class _MultiprocessingSharedStateManager Undocumented
Class _RunningActivity Undocumented
Class _ThreadExceptionRaiser Undocumented
Function _execute_sync_activity Undocumented
Function _proto_to_datetime Undocumented
Function _proto_to_non_zero_timedelta Undocumented
Variable _multiprocess_heartbeat_complete Undocumented
logger = (source)

Undocumented

def _execute_sync_activity(info: temporalio.activity.Info, heartbeat: Union[Callable[..., None], SharedHeartbeatSender], cancel_thread_raiser: Optional[_ThreadExceptionRaiser], cancelled_event: threading.Event, worker_shutdown_event: threading.Event, payload_converter_class_or_instance: Union[Type[temporalio.converter.PayloadConverter], temporalio.converter.PayloadConverter], runtime_metric_meter: Optional[temporalio.common.MetricMeter], fn: Callable[..., Any], *args: Any) -> Any: (source)

Undocumented

def _proto_to_datetime(ts: google.protobuf.timestamp_pb2.Timestamp) -> datetime: (source)

Undocumented

def _proto_to_non_zero_timedelta(dur: google.protobuf.duration_pb2.Duration) -> Optional[timedelta]: (source)

Undocumented

_multiprocess_heartbeat_complete: list[str] = (source)

Undocumented