temporalio.nexus._operation_context

module documentation
(source)

Undocumented

Class Info Information about the running Nexus operation.
Class LoggerAdapter Logger adapter that adds Nexus operation context information.
Class NexusCallback Nexus callback to attach to events such as workflow completion.
Class WorkflowRunOperationContext Context received by a workflow run operation.
Function client Get the Temporal client used by the worker handling the current Nexus operation.
Function in_operation Whether the current code is inside a Nexus operation.
Function info Get the current Nexus operation information.
Variable logger Logger that emits additional data describing the current Nexus operation.
Class _TemporalCancelOperationContext Context for a Nexus cancel operation being handled by a Temporal Nexus Worker.
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
Function _temporal_context Undocumented
Function _try_temporal_context Undocumented
Variable _temporal_cancel_operation_context Undocumented
Variable _temporal_nexus_backing_workflow_start_context Undocumented
Variable _temporal_start_operation_context Undocumented
def client() -> temporalio.client.Client: (source)

Get the Temporal client used by the worker handling the current Nexus operation.

def in_operation() -> bool: (source)

Whether the current code is inside a Nexus operation.

def info() -> Info: (source)

Get the current Nexus operation information.

logger = (source)

Logger that emits additional data describing the current Nexus operation.

def _in_nexus_backing_workflow_start_context() -> bool: (source)

Undocumented

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

Undocumented

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

Undocumented

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

Undocumented

_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