class documentation

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 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, it is converted to a Nexus link and added to the operation's outbound links.

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.