temporalio.nexus._operation_context

module documentation
(source)

Undocumented

Class _TemporalCancelOperationContext Context for a Nexus cancel operation being handled by a Temporal Nexus Worker.
Class _TemporalOperationCtx No class docstring; 0/1 property, 3/6 class variables documented
Class _TemporalStartOperationContext Context for a Nexus start operation being handled by a Temporal Nexus Worker.
Function _in_nexus_backing_workflow_start_context Undocumented
Function _nexus_backing_workflow_start_context Undocumented
Async Function _start_nexus_backing_workflow Undocumented
Function _temporal_context Undocumented
Function _try_temporal_context Undocumented
Type Variable _OperationCtxT Undocumented
Variable _temporal_cancel_operation_context Undocumented
Variable _temporal_nexus_backing_workflow_start_context Undocumented
Variable _temporal_start_operation_context Undocumented
def _in_nexus_backing_workflow_start_context() -> bool: (source)

Undocumented

def _nexus_backing_workflow_start_context() -> Generator[None]: (source)

Undocumented

async def _start_nexus_backing_workflow(temporal_context: _TemporalStartOperationContext, workflow: str | Callable[..., Awaitable[ReturnType]], arg: Any = temporalio.common._arg_unset, *, args: Sequence[Any] = [], id: str, task_queue: str | None = None, result_type: type | None = None, execution_timeout: timedelta | None = None, run_timeout: timedelta | None = None, task_timeout: timedelta | None = None, id_reuse_policy: temporalio.common.WorkflowIDReusePolicy = temporalio.common.WorkflowIDReusePolicy.ALLOW_DUPLICATE, id_conflict_policy: temporalio.common.WorkflowIDConflictPolicy = temporalio.common.WorkflowIDConflictPolicy.UNSPECIFIED, retry_policy: temporalio.common.RetryPolicy | None = None, cron_schedule: str = '', memo: Mapping[str, Any] | None = None, search_attributes: None | temporalio.common.TypedSearchAttributes | temporalio.common.SearchAttributes = None, static_summary: str | None = None, static_details: str | None = None, start_delay: timedelta | None = None, start_signal: str | None = None, start_signal_args: Sequence[Any] = [], rpc_metadata: Mapping[str, str | bytes] = {}, rpc_timeout: timedelta | None = None, request_eager_start: bool = False, priority: temporalio.common.Priority = temporalio.common.Priority.default, versioning_override: temporalio.common.VersioningOverride | None = None) -> WorkflowHandle[ReturnType]: (source)

Undocumented

def _temporal_context() -> _TemporalStartOperationContext | _TemporalCancelOperationContext: (source)

Undocumented

def _try_temporal_context() -> _TemporalStartOperationContext | _TemporalCancelOperationContext | None: (source)

Undocumented

_OperationCtxT = (source)

Undocumented

Value
TypeVar('_OperationCtxT',
        bound=OperationContext)
_temporal_cancel_operation_context: ContextVar[_TemporalCancelOperationContext] = (source)

Undocumented

_temporal_nexus_backing_workflow_start_context: ContextVar[bool] = (source)

Undocumented

_temporal_start_operation_context: ContextVar[_TemporalStartOperationContext] = (source)

Undocumented