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 _apply_nexus_context_to_start_activity_request Apply the current Nexus operation context to an activity start request.
Function _apply_start_activity_response_to_nexus_context Undocumented
Function _in_nexus_backing_start_context Undocumented
Function _nexus_backing_start_context Undocumented
Async Function _start_nexus_backing_workflow Undocumented
Async Function _start_nexus_operation_workflow_update Undocumented
Function _temporal_context Undocumented
Function _try_start_operation_context Return the active Nexus start-operation context, if any.
Function _try_temporal_context Undocumented
Type Variable _OperationCtxT Undocumented
Variable _temporal_cancel_operation_context Undocumented
Variable _temporal_nexus_backing_start_context Undocumented
Variable _temporal_start_operation_context Undocumented
def _apply_nexus_context_to_start_activity_request(req: temporalio.api.workflowservice.v1.StartActivityExecutionRequest): (source)

Apply the current Nexus operation context to an activity start request.

This is a no-op outside a Nexus operation context. Within one, it attaches the Nexus request ID and configures conflict handling to preserve the Nexus metadata. Inbound links are attached to the completion callback when the activity backs the operation and to the request otherwise.

def _apply_start_activity_response_to_nexus_context(activity_id: str, resp: temporalio.api.workflowservice.v1.StartActivityExecutionResponse): (source)

Undocumented

def _in_nexus_backing_start_context() -> bool: (source)

Undocumented

def _nexus_backing_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

async def _start_nexus_operation_workflow_update(*, temporal_context: _TemporalStartOperationContext, workflow_id: str, update: str | Callable, arg: Any = temporalio.common._arg_unset, args: Sequence[Any] = [], update_id: str | None = None, result_type: type | None = None, rpc_metadata: Mapping[str, str | bytes] = {}, rpc_timeout: timedelta | None = None, run_id: str | None = None, first_execution_run_id: str | None = None) -> temporalio.client.WorkflowUpdateHandle[Any]: (source)

Undocumented

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

Undocumented

def _try_start_operation_context() -> _TemporalStartOperationContext | None: (source)

Return the active Nexus start-operation context, if any.

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_start_context: ContextVar[bool] = (source)

Undocumented

_temporal_start_operation_context: ContextVar[_TemporalStartOperationContext] = (source)

Undocumented