temporalio.worker._workflow_instance.

class documentation

class _WorkflowInstanceImpl(WorkflowInstance, temporalio.workflow._Runtime, asyncio.AbstractEventLoop): (source)

Constructor: _WorkflowInstanceImpl(det)

Undocumented

Method	`__init__`	Undocumented
Method	`activate`	Handle an activation and return completion.
Method	`call_at`	Undocumented
Method	`call_exception_handler`	Undocumented
Method	`call_later`	Undocumented
Method	`call_soon`	Undocumented
Method	`create_future`	Undocumented
Method	`create_task`	Undocumented
Method	`default_exception_handler`	Undocumented
Method	`get_debug`	Undocumented
Method	`get_exception_handler`	Undocumented
Method	`get_serialization_context`	Return appropriate serialization context.
Method	`get_task_factory`	Undocumented
Method	`get_thread_id`	Return the thread identifier that this workflow is running on.
Method	`set_exception_handler`	Undocumented
Method	`time`	Undocumented
Method	`workflow_all_handlers_finished`	Undocumented
Method	`workflow_continue_as_new`	Undocumented
Method	`workflow_extern_functions`	Undocumented
Method	`workflow_get_current_build_id`	Undocumented
Method	`workflow_get_current_deployment_version`	Undocumented
Method	`workflow_get_current_details`	Undocumented
Method	`workflow_get_current_history_length`	Undocumented
Method	`workflow_get_current_history_size`	Undocumented
Method	`workflow_get_external_workflow_handle`	Undocumented
Method	`workflow_get_query_handler`	Undocumented
Method	`workflow_get_signal_handler`	Undocumented
Method	`workflow_get_update_handler`	Undocumented
Method	`workflow_get_update_validator`	Undocumented
Method	`workflow_has_last_completion_result`	Undocumented
Method	`workflow_info`	Undocumented
Method	`workflow_instance`	Undocumented
Method	`workflow_is_continue_as_new_suggested`	Undocumented
Method	`workflow_is_failure_exception`	Undocumented
Method	`workflow_is_replaying`	Undocumented
Method	`workflow_last_completion_result`	Undocumented
Method	`workflow_last_failure`	Undocumented
Method	`workflow_memo`	Undocumented
Method	`workflow_memo_value`	Undocumented
Method	`workflow_metric_meter`	Undocumented
Method	`workflow_patch`	Undocumented
Method	`workflow_payload_converter`	Undocumented
Method	`workflow_random`	Undocumented
Method	`workflow_set_current_details`	Undocumented
Method	`workflow_set_query_handler`	Undocumented
Method	`workflow_set_signal_handler`	Undocumented
Method	`workflow_set_update_handler`	Undocumented
Async Method	`workflow_sleep`	Undocumented
Method	`workflow_start_activity`	Undocumented
Async Method	`workflow_start_child_workflow`	Undocumented
Method	`workflow_start_local_activity`	Undocumented
Async Method	`workflow_start_nexus_operation`	Undocumented
Method	`workflow_time_ns`	Undocumented
Method	`workflow_upsert_memo`	Undocumented
Method	`workflow_upsert_search_attributes`	Undocumented
Async Method	`workflow_wait_condition`	Undocumented
Method	`_add_command`	Undocumented
Method	`_apply`	Undocumented
Method	`_apply_cancel_workflow`	Undocumented
Method	`_apply_do_update`	Undocumented
Method	`_apply_fire_timer`	Undocumented
Method	`_apply_initialize_workflow`	Undocumented
Method	`_apply_notify_has_patch`	Undocumented
Method	`_apply_query_workflow`	Undocumented
Method	`_apply_remove_from_cache`	Undocumented
Method	`_apply_resolve_activity`	Undocumented
Method	`_apply_resolve_child_workflow_execution`	Undocumented
Method	`_apply_resolve_child_workflow_execution_start`	Undocumented
Method	`_apply_resolve_nexus_operation`	Undocumented
Method	`_apply_resolve_nexus_operation_start`	Undocumented
Method	`_apply_resolve_request_cancel_external_workflow`	Undocumented
Method	`_apply_resolve_signal_external_workflow`	Undocumented
Method	`_apply_signal_workflow`	Undocumented
Method	`_apply_update_random_seed`	Undocumented
Method	`_as_read_only`	Undocumented
Method	`_assert_not_read_only`	Undocumented
Async Method	`_cancel_external_workflow`	Undocumented
Method	`_check_condition`	Undocumented
Method	`_convert_payloads`	Undocumented
Method	`_enhanced_stack_trace`	Undocumented
Method	`_failure_converter_with_context`	Construct workflow failure converter with the given context.
Method	`_instantiate_workflow_object`	Undocumented
Method	`_make_workflow_input`	Undocumented
Method	`_next_seq`	Undocumented
Method	`_outbound_continue_as_new`	Undocumented
Method	`_outbound_schedule_activity`	Undocumented
Async Method	`_outbound_signal_child_workflow`	Undocumented
Async Method	`_outbound_signal_external_workflow`	Undocumented
Async Method	`_outbound_start_child_workflow`	Undocumented
Async Method	`_outbound_start_nexus_operation`	Undocumented
Method	`_payload_converter_with_context`	Construct workflow payload converter with the given context.
Method	`_process_handler_args`	Undocumented
Method	`_process_signal_job`	Undocumented
Method	`_register_task`	Undocumented
Method	`_run_once`	Undocumented
Async Method	`_run_top_level_workflow_function`	Undocumented
Method	`_set_workflow_failure`	Undocumented
Async Method	`_signal_external_workflow`	Undocumented
Method	`_stack_trace`	Undocumented
Method	`_temporal_workflow_metadata`	Undocumented
Method	`_timer_handle_cancelled`	Undocumented
Method	`_timer_impl`	Undocumented
Method	`_warn_if_unfinished_handlers`	Undocumented
Type Variable	`_Ts`	Undocumented
Instance Variable	`_buffered_signals`	Undocumented
Instance Variable	`_cancel_requested`	Undocumented
Instance Variable	`_conditions`	Undocumented
Instance Variable	`_context_free_failure_converter`	Undocumented
Instance Variable	`_context_free_payload_converter`	Undocumented
Instance Variable	`_continue_as_new_suggested`	Undocumented
Instance Variable	`_curr_seqs`	Undocumented
Instance Variable	`_current_activation_error`	Undocumented
Instance Variable	`_current_completion`	Undocumented
Instance Variable	`_current_details`	Undocumented
Instance Variable	`_current_history_length`	Undocumented
Instance Variable	`_current_history_size`	Undocumented
Instance Variable	`_current_internal_flags`	Undocumented
Instance Variable	`_current_thread_id`	Undocumented
Instance Variable	`_defn`	Undocumented
Instance Variable	`_deleting`	Undocumented
Instance Variable	`_deployment_version_for_current_task`	Undocumented
Instance Variable	`_disable_eager_activity_execution`	Undocumented
Instance Variable	`_dynamic_failure_exception_types`	Undocumented
Instance Variable	`_exception_handler`	Undocumented
Instance Variable	`_extern_functions`	Undocumented
Instance Variable	`_handled_signals_seq`	Undocumented
Instance Variable	`_in_progress_signals`	Undocumented
Instance Variable	`_in_progress_updates`	Undocumented
Instance Variable	`_inbound`	Undocumented
Instance Variable	`_info`	Undocumented
Instance Variable	`_is_replaying`	Undocumented
Instance Variable	`_last_completion_result`	Undocumented
Instance Variable	`_last_failure`	Undocumented
Instance Variable	`_metric_meter`	Undocumented
Instance Variable	`_object`	Undocumented
Instance Variable	`_outbound`	Undocumented
Instance Variable	`_patches_memoized`	Undocumented
Instance Variable	`_patches_notified`	Undocumented
Instance Variable	`_pending_activities`	Undocumented
Instance Variable	`_pending_child_workflows`	Undocumented
Instance Variable	`_pending_external_cancels`	Undocumented
Instance Variable	`_pending_external_signals`	Undocumented
Instance Variable	`_pending_nexus_operations`	Undocumented
Instance Variable	`_pending_timers`	Undocumented
Instance Variable	`_primary_task`	Undocumented
Instance Variable	`_queries`	Undocumented
Instance Variable	`_random`	Undocumented
Instance Variable	`_read_only`	Undocumented
Instance Variable	`_ready`	Undocumented
Instance Variable	`_signals`	Undocumented
Instance Variable	`_tasks`	Undocumented
Instance Variable	`_time_ns`	Undocumented
Instance Variable	`_untyped_converted_memo`	Undocumented
Instance Variable	`_updates`	Undocumented
Instance Variable	`_versioning_behavior`	Undocumented
Instance Variable	`_worker_level_failure_exception_types`	Undocumented
Instance Variable	`_workflow_context_failure_converter`	Undocumented
Instance Variable	`_workflow_context_payload_converter`	Undocumented
Instance Variable	`_workflow_input`	Undocumented

Inherited from _Runtime (via WorkflowInstance):

Static Method	`current`	Undocumented
Static Method	`maybe_current`	Undocumented
Static Method	`set_on_loop`	Undocumented
Property	`logger_details`	Undocumented
Instance Variable	`_logger_details`	Undocumented

def __init__(self, det: WorkflowInstanceDetails): (source) ¶

overrides temporalio.workflow._Runtime.__init__

Undocumented

def activate(self, act: temporalio.bridge.proto.workflow_activation.WorkflowActivation) -> temporalio.bridge.proto.workflow_completion.WorkflowActivationCompletion: (source) ¶

overrides temporalio.worker.WorkflowInstance.activate

Handle an activation and return completion.

This should never raise an exception, but instead catch all exceptions and set as completion failure.

Parameters
act:`temporalio.bridge.proto.workflow_activation.WorkflowActivation`	Protobuf activation.
Returns
`temporalio.bridge.proto.workflow_completion.WorkflowActivationCompletion`	Completion object with successful commands set or failure info set.

def call_at(self, when: float, callback: Callable[[Unpack[_Ts]], object], *args: Unpack[_Ts], context: contextvars.Context | None = None) -> asyncio.TimerHandle: (source) ¶

Undocumented

def call_exception_handler(self, context: _Context): (source) ¶

Undocumented

def call_later(self, delay: float, callback: Callable[[Unpack[_Ts]], object], *args: Unpack[_Ts], context: contextvars.Context | None = None) -> asyncio.TimerHandle: (source) ¶

Undocumented

def call_soon(self, callback: Callable[[Unpack[_Ts]], object], *args: Unpack[_Ts], context: contextvars.Context | None = None) -> asyncio.Handle: (source) ¶

Undocumented

def create_future(self) -> asyncio.Future[Any]: (source) ¶

Undocumented

def create_task(self, coro: Awaitable[_T] | Generator[Any, None, _T], *, name: str | None = None, context: contextvars.Context | None = None) -> asyncio.Task[_T]: (source) ¶

Undocumented

def default_exception_handler(self, context: _Context): (source) ¶

Undocumented

def get_debug(self) -> bool: (source) ¶

Undocumented

def get_exception_handler(self) -> _ExceptionHandler | None: (source) ¶

Undocumented

def get_serialization_context(self, command_info: _command_aware_visitor.CommandInfo | None) -> temporalio.converter.SerializationContext | None: (source) ¶

overrides temporalio.worker.WorkflowInstance.get_serialization_context

Return appropriate serialization context.

Parameters
command_info:`_command_aware_visitor.CommandInfo \| None`	Optional information identifying the associated command. If set, the payload codec will have serialization context set appropriately for that command.
Returns
`temporalio.converter.SerializationContext \| None`	The serialization context, or None if no context should be set.

def get_task_factory(self): (source) ¶

Undocumented

def get_thread_id(self) -> int | None: (source) ¶

overrides temporalio.worker.WorkflowInstance.get_thread_id

Return the thread identifier that this workflow is running on.

Not an abstractmethod because it is not mandatory to implement. Used primarily for getting the frames of a deadlocked thread.

Returns
`int \| None`	Thread ID if the workflow is running, None if not.

def set_exception_handler(self, handler: _ExceptionHandler | None): (source) ¶

Undocumented

def time(self) -> float: (source) ¶

Undocumented

def workflow_all_handlers_finished(self) -> bool: (source) ¶

overrides temporalio.workflow._Runtime.workflow_all_handlers_finished

Undocumented

overrides temporalio.workflow._Runtime.workflow_continue_as_new

Undocumented

def workflow_extern_functions(self) -> Mapping[str, Callable]: (source) ¶

overrides temporalio.workflow._Runtime.workflow_extern_functions

Undocumented

def workflow_get_current_build_id(self) -> str: (source) ¶

overrides temporalio.workflow._Runtime.workflow_get_current_build_id

Undocumented

def workflow_get_current_deployment_version(self) -> temporalio.common.WorkerDeploymentVersion | None: (source) ¶

overrides temporalio.workflow._Runtime.workflow_get_current_deployment_version

Undocumented

def workflow_get_current_details(self) -> str: (source) ¶

overrides temporalio.workflow._Runtime.workflow_get_current_details

Undocumented

def workflow_get_current_history_length(self) -> int: (source) ¶

overrides temporalio.workflow._Runtime.workflow_get_current_history_length

Undocumented

def workflow_get_current_history_size(self) -> int: (source) ¶

overrides temporalio.workflow._Runtime.workflow_get_current_history_size

Undocumented

def workflow_get_external_workflow_handle(self, id: str, *, run_id: str | None) -> temporalio.workflow.ExternalWorkflowHandle[Any]: (source) ¶

overrides temporalio.workflow._Runtime.workflow_get_external_workflow_handle

Undocumented

def workflow_get_query_handler(self, name: str | None) -> Callable | None: (source) ¶

overrides temporalio.workflow._Runtime.workflow_get_query_handler

Undocumented

def workflow_get_signal_handler(self, name: str | None) -> Callable | None: (source) ¶

overrides temporalio.workflow._Runtime.workflow_get_signal_handler

Undocumented

def workflow_get_update_handler(self, name: str | None) -> Callable | None: (source) ¶

overrides temporalio.workflow._Runtime.workflow_get_update_handler

Undocumented

def workflow_get_update_validator(self, name: str | None) -> Callable | None: (source) ¶

overrides temporalio.workflow._Runtime.workflow_get_update_validator

Undocumented

def workflow_has_last_completion_result(self) -> bool: (source) ¶

overrides temporalio.workflow._Runtime.workflow_has_last_completion_result

Undocumented

def workflow_info(self) -> temporalio.workflow.Info: (source) ¶

overrides temporalio.workflow._Runtime.workflow_info

Undocumented

def workflow_instance(self) -> Any: (source) ¶

overrides temporalio.workflow._Runtime.workflow_instance

Undocumented

def workflow_is_continue_as_new_suggested(self) -> bool: (source) ¶

overrides temporalio.workflow._Runtime.workflow_is_continue_as_new_suggested

Undocumented

def workflow_is_failure_exception(self, err: BaseException) -> bool: (source) ¶

overrides temporalio.workflow._Runtime.workflow_is_failure_exception

Undocumented

def workflow_is_replaying(self) -> bool: (source) ¶

overrides temporalio.workflow._Runtime.workflow_is_replaying

Undocumented

def workflow_last_completion_result(self, type_hint: type | None) -> Any | None: (source) ¶

overrides temporalio.workflow._Runtime.workflow_last_completion_result

Undocumented

def workflow_last_failure(self) -> BaseException | None: (source) ¶

overrides temporalio.workflow._Runtime.workflow_last_failure

Undocumented

def workflow_memo(self) -> Mapping[str, Any]: (source) ¶

overrides temporalio.workflow._Runtime.workflow_memo

Undocumented

def workflow_memo_value(self, key: str, default: Any, *, type_hint: type | None) -> Any: (source) ¶

overrides temporalio.workflow._Runtime.workflow_memo_value

Undocumented

def workflow_metric_meter(self) -> temporalio.common.MetricMeter: (source) ¶

overrides temporalio.workflow._Runtime.workflow_metric_meter

Undocumented

def workflow_patch(self, id: str, *, deprecated: bool) -> bool: (source) ¶

overrides temporalio.workflow._Runtime.workflow_patch

Undocumented

def workflow_payload_converter(self) -> temporalio.converter.PayloadConverter: (source) ¶

overrides temporalio.workflow._Runtime.workflow_payload_converter

Undocumented

def workflow_random(self) -> random.Random: (source) ¶

overrides temporalio.workflow._Runtime.workflow_random

Undocumented

def workflow_set_current_details(self, details: str): (source) ¶

overrides temporalio.workflow._Runtime.workflow_set_current_details

Undocumented

def workflow_set_query_handler(self, name: str | None, handler: Callable | None): (source) ¶

overrides temporalio.workflow._Runtime.workflow_set_query_handler

Undocumented

def workflow_set_signal_handler(self, name: str | None, handler: Callable | None): (source) ¶

overrides temporalio.workflow._Runtime.workflow_set_signal_handler

Undocumented

def workflow_set_update_handler(self, name: str | None, handler: Callable | None, validator: Callable | None): (source) ¶

overrides temporalio.workflow._Runtime.workflow_set_update_handler

Undocumented

async def workflow_sleep(self, duration: float, *, summary: str | None = None): (source) ¶

overrides temporalio.workflow._Runtime.workflow_sleep

Undocumented

def workflow_start_activity(self, activity: Any, *args: Any, task_queue: str | None, result_type: type | None, schedule_to_close_timeout: timedelta | None, schedule_to_start_timeout: timedelta | None, start_to_close_timeout: timedelta | None, heartbeat_timeout: timedelta | None, retry_policy: temporalio.common.RetryPolicy | None, cancellation_type: temporalio.workflow.ActivityCancellationType, activity_id: str | None, versioning_intent: temporalio.workflow.VersioningIntent | None, summary: str | None = None, priority: temporalio.common.Priority = temporalio.common.Priority.default) -> temporalio.workflow.ActivityHandle[Any]: (source) ¶

overrides temporalio.workflow._Runtime.workflow_start_activity

Undocumented

async def workflow_start_child_workflow(self, workflow: Any, *args: Any, id: str, task_queue: str | None, result_type: type | None, cancellation_type: temporalio.workflow.ChildWorkflowCancellationType, parent_close_policy: temporalio.workflow.ParentClosePolicy, execution_timeout: timedelta | None, run_timeout: timedelta | None, task_timeout: timedelta | None, id_reuse_policy: temporalio.common.WorkflowIDReusePolicy, retry_policy: temporalio.common.RetryPolicy | None, cron_schedule: str, memo: Mapping[str, Any] | None, search_attributes: temporalio.common.SearchAttributes | temporalio.common.TypedSearchAttributes | None, versioning_intent: temporalio.workflow.VersioningIntent | None, static_summary: str | None = None, static_details: str | None = None, priority: temporalio.common.Priority = temporalio.common.Priority.default) -> temporalio.workflow.ChildWorkflowHandle[Any, Any]: (source) ¶

overrides temporalio.workflow._Runtime.workflow_start_child_workflow

Undocumented

def workflow_start_local_activity(self, activity: Any, *args: Any, result_type: type | None, schedule_to_close_timeout: timedelta | None, schedule_to_start_timeout: timedelta | None, start_to_close_timeout: timedelta | None, retry_policy: temporalio.common.RetryPolicy | None, local_retry_threshold: timedelta | None, cancellation_type: temporalio.workflow.ActivityCancellationType, activity_id: str | None, summary: str | None) -> temporalio.workflow.ActivityHandle[Any]: (source) ¶

overrides temporalio.workflow._Runtime.workflow_start_local_activity

Undocumented

async def workflow_start_nexus_operation(self, endpoint: str, service: str, operation: nexusrpc.Operation[InputT, OutputT] | str | Callable[..., Any], input: Any, output_type: type[OutputT] | None, schedule_to_close_timeout: timedelta | None, cancellation_type: temporalio.workflow.NexusOperationCancellationType, headers: Mapping[str, str] | None) -> temporalio.workflow.NexusOperationHandle[OutputT]: (source) ¶

overrides temporalio.workflow._Runtime.workflow_start_nexus_operation

Undocumented

def workflow_time_ns(self) -> int: (source) ¶

overrides temporalio.workflow._Runtime.workflow_time_ns

Undocumented

def workflow_upsert_memo(self, updates: Mapping[str, Any]): (source) ¶

overrides temporalio.workflow._Runtime.workflow_upsert_memo

Undocumented

def workflow_upsert_search_attributes(self, attributes: temporalio.common.SearchAttributes | Sequence[temporalio.common.SearchAttributeUpdate]): (source) ¶

overrides temporalio.workflow._Runtime.workflow_upsert_search_attributes

Undocumented

async def workflow_wait_condition(self, fn: Callable[[], bool], *, timeout: float | None = None, timeout_summary: str | None = None): (source) ¶

overrides temporalio.workflow._Runtime.workflow_wait_condition

Undocumented

def _add_command(self) -> temporalio.bridge.proto.workflow_commands.WorkflowCommand: (source) ¶

Undocumented

def _apply(self, job: temporalio.bridge.proto.workflow_activation.WorkflowActivationJob): (source) ¶

Undocumented

def _apply_cancel_workflow(self, job: temporalio.bridge.proto.workflow_activation.CancelWorkflow): (source) ¶

Undocumented

def _apply_do_update(self, job: temporalio.bridge.proto.workflow_activation.DoUpdate): (source) ¶

Undocumented

def _apply_fire_timer(self, job: temporalio.bridge.proto.workflow_activation.FireTimer): (source) ¶

Undocumented

def _apply_initialize_workflow(self, job: temporalio.bridge.proto.workflow_activation.InitializeWorkflow): (source) ¶

Undocumented

def _apply_notify_has_patch(self, job: temporalio.bridge.proto.workflow_activation.NotifyHasPatch): (source) ¶

Undocumented

def _apply_query_workflow(self, job: temporalio.bridge.proto.workflow_activation.QueryWorkflow): (source) ¶

Undocumented

def _apply_remove_from_cache(self, job: temporalio.bridge.proto.workflow_activation.RemoveFromCache): (source) ¶

Undocumented

def _apply_resolve_activity(self, job: temporalio.bridge.proto.workflow_activation.ResolveActivity): (source) ¶

Undocumented

def _apply_resolve_child_workflow_execution(self, job: temporalio.bridge.proto.workflow_activation.ResolveChildWorkflowExecution): (source) ¶

Undocumented

def _apply_resolve_child_workflow_execution_start(self, job: temporalio.bridge.proto.workflow_activation.ResolveChildWorkflowExecutionStart): (source) ¶

Undocumented

def _apply_resolve_nexus_operation(self, job: temporalio.bridge.proto.workflow_activation.ResolveNexusOperation): (source) ¶

Undocumented

def _apply_resolve_nexus_operation_start(self, job: temporalio.bridge.proto.workflow_activation.ResolveNexusOperationStart): (source) ¶

Undocumented

def _apply_resolve_request_cancel_external_workflow(self, job: temporalio.bridge.proto.workflow_activation.ResolveRequestCancelExternalWorkflow): (source) ¶

Undocumented

def _apply_resolve_signal_external_workflow(self, job: temporalio.bridge.proto.workflow_activation.ResolveSignalExternalWorkflow): (source) ¶

Undocumented

def _apply_signal_workflow(self, job: temporalio.bridge.proto.workflow_activation.SignalWorkflow): (source) ¶

Undocumented

def _apply_update_random_seed(self, job: temporalio.bridge.proto.workflow_activation.UpdateRandomSeed): (source) ¶

Undocumented

@contextmanager
def _as_read_only(self) -> Iterator[None]: (source) ¶

Undocumented

def _assert_not_read_only(self, action_attempted: str, *, allow_during_delete: bool = False): (source) ¶

Undocumented

async def _cancel_external_workflow(self, command: temporalio.bridge.proto.workflow_commands.WorkflowCommand): (source) ¶

Undocumented

def _check_condition(self, fn: Callable[[], bool], fut: asyncio.Future) -> bool: (source) ¶

Undocumented

def _convert_payloads(self, payloads: Sequence[temporalio.api.common.v1.Payload], types: list[type] | None, payload_converter: temporalio.converter.PayloadConverter) -> list[Any]: (source) ¶

Undocumented

def _enhanced_stack_trace(self) -> temporalio.api.sdk.v1.EnhancedStackTrace: (source) ¶

Undocumented

def _failure_converter_with_context(self, context: temporalio.converter.SerializationContext) -> temporalio.converter.FailureConverter: (source) ¶

Construct workflow failure converter with the given context.

This plays a similar role to DataConverter._with_context, but operates on FailureConverter only (payload encoding/decoding is done by the worker, outside the workflow sandbox).

def _instantiate_workflow_object(self) -> Any: (source) ¶

Undocumented

def _make_workflow_input(self, init_job: temporalio.bridge.proto.workflow_activation.InitializeWorkflow) -> ExecuteWorkflowInput: (source) ¶

Undocumented

def _next_seq(self, type: str) -> int: (source) ¶

Undocumented

def _outbound_continue_as_new(self, input: ContinueAsNewInput) -> NoReturn: (source) ¶

Undocumented

def _outbound_schedule_activity(self, input: StartActivityInput | StartLocalActivityInput) -> _ActivityHandle: (source) ¶

Undocumented

async def _outbound_signal_child_workflow(self, input: SignalChildWorkflowInput): (source) ¶

Undocumented

async def _outbound_signal_external_workflow(self, input: SignalExternalWorkflowInput): (source) ¶

Undocumented

async def _outbound_start_child_workflow(self, input: StartChildWorkflowInput) -> _ChildWorkflowHandle: (source) ¶

Undocumented

async def _outbound_start_nexus_operation(self, input: StartNexusOperationInput[Any, OutputT]) -> _NexusOperationHandle[OutputT]: (source) ¶

Undocumented

def _payload_converter_with_context(self, context: temporalio.converter.SerializationContext) -> temporalio.converter.PayloadConverter: (source) ¶

Construct workflow payload converter with the given context.

This plays a similar role to DataConverter._with_context, but operates on PayloadConverter only (payload encoding/decoding is done by the worker, outside the workflow sandbox).

def _process_handler_args(self, job_name: str, job_input: Sequence[temporalio.api.common.v1.Payload], defn_name: str | None, defn_arg_types: list[type] | None, defn_dynamic_vararg: bool) -> list[Any]: (source) ¶

Undocumented

def _process_signal_job(self, defn: temporalio.workflow._SignalDefinition, job: temporalio.bridge.proto.workflow_activation.SignalWorkflow): (source) ¶

Undocumented

def _register_task(self, task: asyncio.Task, *, name: str | None): (source) ¶

Undocumented

def _run_once(self, *, check_conditions: bool): (source) ¶

Undocumented

async def _run_top_level_workflow_function(self, coro: Awaitable[None]): (source) ¶

Undocumented

def _set_workflow_failure(self, err: BaseException): (source) ¶

Undocumented

async def _signal_external_workflow(self, command: temporalio.bridge.proto.workflow_commands.WorkflowCommand): (source) ¶

Undocumented

def _stack_trace(self) -> str: (source) ¶

Undocumented

def _temporal_workflow_metadata(self) -> temporalio.api.sdk.v1.WorkflowMetadata: (source) ¶

Undocumented

def _timer_handle_cancelled(self, handle: asyncio.TimerHandle): (source) ¶

Undocumented

def _timer_impl(self, delay: float, options: _TimerOptions, callback: Callable[..., Any], *args: Any, context: contextvars.Context | None = None): (source) ¶

Undocumented

def _warn_if_unfinished_handlers(self): (source) ¶

Undocumented

_Ts = (source) ¶

Undocumented

Value