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: Callable[..., None] | SharedHeartbeatSender, cancel_thread_raiser: _ThreadExceptionRaiser | None, cancelled_event: threading.Event, worker_shutdown_event: threading.Event, payload_converter_class_or_instance: type[temporalio.converter.PayloadConverter] | temporalio.converter.PayloadConverter, runtime_metric_meter: temporalio.common.MetricMeter | None, 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) -> timedelta | None: (source)

Undocumented

_multiprocess_heartbeat_complete: list[str] = (source)

Undocumented