temporalio.worker._activity

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, cancellation_details: temporalio.activity._ActivityCancellationDetailsHolder, fn: Callable[..., Any], *args: Any) -> Any: (source) ΒΆ