temporalio.worker._workflow_instance

module documentation
(source)

Workflow worker runner and instance.

Constant LOG_IGNORE_DURING_DELETE Undocumented
Variable logger Undocumented
Class _ActivityHandle Undocumented
Class _ChildWorkflowHandle Undocumented
Class _ExternalWorkflowHandle Undocumented
Class _ReplaySafeMetricCommon Undocumented
Class _ReplaySafeMetricCounter Undocumented
Class _ReplaySafeMetricGauge Undocumented
Class _ReplaySafeMetricGaugeFloat Undocumented
Class _ReplaySafeMetricHistogram Undocumented
Class _ReplaySafeMetricHistogramFloat Undocumented
Class _ReplaySafeMetricHistogramTimedelta Undocumented
Class _ReplaySafeMetricMeter Undocumented
Class _TimerHandle Undocumented
Class _WorkflowExternFunctions Undocumented
Class _WorkflowInboundImpl Undocumented
Class _WorkflowInstanceImpl Undocumented
Class _WorkflowOutboundImpl Undocumented
Exception _ActivityDoBackoffError Undocumented
Exception _ContinueAsNewError Undocumented
Function _encode_search_attributes Undocumented
Type Variable _MetricType Undocumented
Type Variable _T Undocumented
Type Alias _Context Undocumented
Type Alias _ExceptionHandler Undocumented
LOG_IGNORE_DURING_DELETE: bool = (source)

Undocumented

Value
False
logger = (source)

Undocumented

def _encode_search_attributes(attributes: Union[temporalio.common.SearchAttributes, temporalio.common.TypedSearchAttributes], payloads: Mapping[str, temporalio.api.common.v1.Payload]): (source)

Undocumented

_MetricType = (source)

Undocumented

Value
TypeVar('_MetricType',
        bound=temporalio.common.MetricCommon)
_T = (source)

Undocumented

Value
TypeVar('_T')
_Context: TypeAlias = (source)

Undocumented

Value
Dict[str, Any]
_ExceptionHandler: TypeAlias = (source)

Undocumented

Value
Callable[[asyncio.AbstractEventLoop, _Context], Any]