temporalio.workflow._Runtime

class documentation

class _Runtime(ABC): (source)

Known subclasses: temporalio.worker._workflow_instance._WorkflowInstanceImpl

Constructor: _Runtime.current()

View In Hierarchy

Undocumented

Static Method current Undocumented
Static Method maybe_current Undocumented
Static Method set_on_loop Undocumented
Method __init__ 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_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_info Undocumented
Method workflow_is_continue_as_new_suggested Undocumented
Method workflow_is_replaying 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
Method workflow_time_ns Undocumented
Method workflow_upsert_search_attributes Undocumented
Async Method workflow_wait_condition Undocumented
Property logger_details Undocumented
Instance Variable _logger_details Undocumented
@staticmethod
def current() -> _Runtime: (source)

Undocumented

@staticmethod
def maybe_current() -> _Runtime | None: (source)

Undocumented

@staticmethod
def set_on_loop(loop: asyncio.AbstractEventLoop, runtime: _Runtime | None): (source)

Undocumented

def __init__(self): (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_all_handlers_finished(self) -> bool: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_continue_as_new(self, *args: Any, workflow: None | Callable | str, task_queue: str | None, run_timeout: timedelta | None, task_timeout: timedelta | None, retry_policy: temporalio.common.RetryPolicy | None, memo: Mapping[str, Any] | None, search_attributes: temporalio.common.SearchAttributes | temporalio.common.TypedSearchAttributes | None, versioning_intent: VersioningIntent | None) -> NoReturn: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_extern_functions(self) -> Mapping[str, Callable]: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_get_current_build_id(self) -> str: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_get_current_details(self) -> str: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_get_current_history_length(self) -> int: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_get_current_history_size(self) -> int: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_get_external_workflow_handle(self, id: str, *, run_id: str | None) -> ExternalWorkflowHandle[Any]: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_get_query_handler(self, name: str | None) -> Callable | None: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_get_signal_handler(self, name: str | None) -> Callable | None: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_get_update_handler(self, name: str | None) -> Callable | None: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_get_update_validator(self, name: str | None) -> Callable | None: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_info(self) -> Info: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_is_continue_as_new_suggested(self) -> bool: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_is_replaying(self) -> bool: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_memo(self) -> Mapping[str, Any]: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_memo_value(self, key: str, default: Any, *, type_hint: type | None) -> Any: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_metric_meter(self) -> temporalio.common.MetricMeter: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_patch(self, id: str, *, deprecated: bool) -> bool: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_payload_converter(self) -> temporalio.converter.PayloadConverter: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_random(self) -> Random: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_set_current_details(self, details: str): (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_set_query_handler(self, name: str | None, handler: Callable | None): (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_set_signal_handler(self, name: str | None, handler: Callable | None): (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_set_update_handler(self, name: str | None, handler: Callable | None, validator: Callable | None): (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
async def workflow_sleep(self, duration: float, *, summary: str | None = None): (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
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: ActivityCancellationType, activity_id: str | None, versioning_intent: VersioningIntent | None, summary: str | None = None) -> ActivityHandle[Any]: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
async def workflow_start_child_workflow(self, workflow: Any, *args: Any, id: str, task_queue: str | None, result_type: type | None, cancellation_type: ChildWorkflowCancellationType, parent_close_policy: 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: VersioningIntent | None, static_summary: str | None = None, static_details: str | None = None) -> ChildWorkflowHandle[Any, Any]: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
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: ActivityCancellationType, activity_id: str | None) -> ActivityHandle[Any]: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_time_ns(self) -> int: (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_upsert_search_attributes(self, attributes: temporalio.common.SearchAttributes | Sequence[temporalio.common.SearchAttributeUpdate]): (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
async def workflow_wait_condition(self, fn: Callable[[], bool], *, timeout: float | None = None, timeout_summary: str | None = None): (source)
overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@property
logger_details: Mapping[str, Any] = (source)

Undocumented

_logger_details: Mapping[str, Any] | None = (source)

Undocumented