temporalio.workflow._Runtime

Modules Classes Names

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_continue_as_new`	Undocumented
Method	`workflow_extern_functions`	Undocumented
Method	`workflow_get_current_build_id`	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_query_handler`	Undocumented
Method	`workflow_set_signal_handler`	Undocumented
Method	`workflow_set_update_handler`	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() -> Optional[_Runtime]: (source) ¶

Undocumented

@staticmethod
def set_on_loop(loop: asyncio.AbstractEventLoop, runtime: Optional[_Runtime]): (source) ¶

Undocumented

def __init__(self): (source) ¶

overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_continue_as_new(self, *args: Any, workflow: Union[None, Callable, str], task_queue: Optional[str], run_timeout: Optional[timedelta], task_timeout: Optional[timedelta], retry_policy: Optional[temporalio.common.RetryPolicy], memo: Optional[Mapping[str, Any]], search_attributes: Optional[Union[temporalio.common.SearchAttributes, temporalio.common.TypedSearchAttributes]], versioning_intent: Optional[VersioningIntent]) -> 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_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: Optional[str]) -> ExternalWorkflowHandle[Any]: (source) ¶

overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_get_query_handler(self, name: Optional[str]) -> Optional[Callable]: (source) ¶

overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_get_signal_handler(self, name: Optional[str]) -> Optional[Callable]: (source) ¶

overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_get_update_handler(self, name: Optional[str]) -> Optional[Callable]: (source) ¶

overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_get_update_validator(self, name: Optional[str]) -> Optional[Callable]: (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: Optional[Type]) -> 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_query_handler(self, name: Optional[str], handler: Optional[Callable]): (source) ¶

overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_set_signal_handler(self, name: Optional[str], handler: Optional[Callable]): (source) ¶

overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_set_update_handler(self, name: Optional[str], handler: Optional[Callable], validator: Optional[Callable]): (source) ¶

overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

@abstractmethod
def workflow_start_activity(self, activity: Any, *args: Any, task_queue: Optional[str], result_type: Optional[Type], schedule_to_close_timeout: Optional[timedelta], schedule_to_start_timeout: Optional[timedelta], start_to_close_timeout: Optional[timedelta], heartbeat_timeout: Optional[timedelta], retry_policy: Optional[temporalio.common.RetryPolicy], cancellation_type: ActivityCancellationType, activity_id: Optional[str], versioning_intent: Optional[VersioningIntent]) -> 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: Optional[str], result_type: Optional[Type], cancellation_type: ChildWorkflowCancellationType, parent_close_policy: ParentClosePolicy, execution_timeout: Optional[timedelta], run_timeout: Optional[timedelta], task_timeout: Optional[timedelta], id_reuse_policy: temporalio.common.WorkflowIDReusePolicy, retry_policy: Optional[temporalio.common.RetryPolicy], cron_schedule: str, memo: Optional[Mapping[str, Any]], search_attributes: Optional[Union[temporalio.common.SearchAttributes, temporalio.common.TypedSearchAttributes]], versioning_intent: Optional[VersioningIntent]) -> 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: Optional[Type], schedule_to_close_timeout: Optional[timedelta], schedule_to_start_timeout: Optional[timedelta], start_to_close_timeout: Optional[timedelta], retry_policy: Optional[temporalio.common.RetryPolicy], local_retry_threshold: Optional[timedelta], cancellation_type: ActivityCancellationType, activity_id: Optional[str]) -> 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: Union[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: Optional[float] = None): (source) ¶

overridden in temporalio.worker._workflow_instance._WorkflowInstanceImpl

Undocumented

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

Undocumented

_logger_details: Optional[Mapping[str, Any]] = (source) ¶

Undocumented