temporalio.worker._workflow

temporalio.worker._workflow_instance

module documentation

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	`_NexusOperationHandle`	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`	No class docstring; 0/59 instance variable, 0/1 type variable, 2/108 methods documented
Class	`_WorkflowLogicFlag`	Flags that may be set on task/activation completion to differentiate new from old workflow behavior.
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