temporalio.workflow._Definition

temporalio.workflow._Definition

class documentation

class _Definition: (source)

Constructors: _Definition.must_from_class(cls), _Definition.must_from_run_fn(fn)

View In Hierarchy

Undocumented

def get_name_and_result_type(cls, name_or_run_fn: str | Callable[..., Awaitable[Any]]) -> tuple[str, type | None]: (source)

Undocumented

def from_class(cls: type) -> _Definition | None: (source)

Undocumented

def from_run_fn(fn: Callable[..., Awaitable[Any]]) -> _Definition | None: (source)

Undocumented

def must_from_class(cls: type) -> _Definition: (source)

Undocumented

def must_from_run_fn(fn: Callable[..., Awaitable[Any]]) -> _Definition: (source)

Undocumented

def __post_init__(self): (source)

Undocumented

arg_types: list[type] | None = (source)

Undocumented

cls: type = (source)

Undocumented

dynamic_config_fn: Callable[..., DynamicWorkflowConfig] | None = (source)

Undocumented

failure_exception_types: Sequence[type[BaseException]] = (source)

Undocumented

name: str | None = (source)

Undocumented

queries: Mapping[str | None, _QueryDefinition] = (source)

Undocumented

ret_type: type | None = (source)

Undocumented

run_fn: Callable[..., Awaitable] = (source)

Undocumented

sandboxed: bool = (source)

Undocumented

signals: Mapping[str | None, _SignalDefinition] = (source)

Undocumented

updates: Mapping[str | None, _UpdateDefinition] = (source)

Undocumented

versioning_behavior: temporalio.common.VersioningBehavior | None = (source)

Undocumented

def _apply_to_class(cls: type, *, workflow_name: str | None, sandboxed: bool, failure_exception_types: Sequence[type[BaseException]], versioning_behavior: temporalio.common.VersioningBehavior): (source)

Undocumented