temporalio.nexus._operation_context._TemporalStartOperationContext

class documentation

class _TemporalStartOperationContext(_TemporalOperationCtx[StartOperationContext]): (source)

Constructor: _TemporalStartOperationContext.get()

View In Hierarchy

Context for a Nexus start operation being handled by a Temporal Nexus Worker.

Class Method get Undocumented
Method set Undocumented
Method _add_response_link Append a response link returned by an RPC the operation handler issued.
Method _add_start_workflow_response_link Undocumented
Method _get_callbacks Undocumented
Method _get_request_links Request links to attach to RPCs the operation handler issues.

Inherited from _TemporalOperationCtx:

Class Variable client The Temporal client in use by the worker handling the current Nexus operation.
Class Variable info Temporal information about the running Nexus operation.
Class Variable nexus_context Nexus-specific start operation context.
Property metric_meter Undocumented
Class Variable _metric_meter Undocumented
Class Variable _runtime_metric_meter Undocumented
Class Variable _worker_shutdown_event Undocumented
def get(cls) -> _TemporalStartOperationContext: (source)

Undocumented

def set(self): (source)

Undocumented

def _add_response_link(self, link: temporalio.api.common.v1.Link | None): (source)

Append a response link returned by an RPC the operation handler issued.

link is the common.v1.Link returned on a signal, signal-with-start, or start response (or None against a server that did not return one). When present and of the workflow_event variant, it is converted to a Nexus link and added to the operation's outbound links so the caller workflow's Nexus history event links to the callee event.

This is only safe to call from the single thread/task that runs the operation handler.

def _add_start_workflow_response_link(self, workflow_handle: temporalio.client.WorkflowHandle[Any, Any]): (source)

Undocumented

def _get_callbacks(self, token: str) -> list[temporalio.client.Callback]: (source)

Undocumented

def _get_request_links(self) -> list[temporalio.api.common.v1.Link]: (source)

Request links to attach to RPCs the operation handler issues.

These are the inbound Nexus task links. When the operation handler signals, signal-with-starts, or starts a workflow, these links are added to the request's links field so the callee's history event links back to whatever scheduled this Nexus operation.