temporalio.worker._workflow_instance

module documentation
(source)

Workflow worker runner and instance.

Class HandlerExecution Information about an execution of a signal or update handler.
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 _TimerOptions Undocumented
Class _WorkflowExternFunctions Undocumented
Class _WorkflowInboundImpl Undocumented
Class _WorkflowInstanceImpl Undocumented
Class _WorkflowOutboundImpl Undocumented
Exception _ActivityDoBackoffError Undocumented
Exception _ContinueAsNewError Undocumented
Exception _WorkflowBeingEvictedError Undocumented
Function _encode_search_attributes Undocumented
Function _make_unfinished_signal_handler_message Undocumented
Function _make_unfinished_update_handler_message Undocumented
Type Variable _MetricType Undocumented
Type Variable _T Undocumented
Type Alias _Context Undocumented
Type Alias _ExceptionHandler Undocumented
Variable _TimerOptionsCtxVar Undocumented
LOG_IGNORE_DURING_DELETE: bool = (source)

Undocumented

Value
False
logger = (source)

Undocumented

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

Undocumented

def _make_unfinished_signal_handler_message(handler_executions: list[HandlerExecution]) -> str: (source)

Undocumented

def _make_unfinished_update_handler_message(handler_executions: list[HandlerExecution]) -> str: (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]
_TimerOptionsCtxVar: contextvars.ContextVar[_TimerOptions] = (source)

Undocumented