temporalio.worker._activity
def _execute_sync_activity(info: temporalio.activity.Info, heartbeat: Callable[, cancel_thread_raiser: _ThreadExceptionRaiser | None, cancelled_event: threading.Event, worker_shutdown_event: threading.Event, payload_converter_class_or_instance: type[, runtime_metric_meter: temporalio.common.MetricMeter | None, cancellation_details: temporalio.activity._ActivityCancellationDetailsHolder, fn: Callable[, *args: Any) -> Any:
(source)
ΒΆ