temporalio.worker._workflow_instance.

class documentation

class _NexusOperationHandle(temporalio.workflow.NexusOperationHandle[OutputT]): (source)

Constructor: _NexusOperationHandle(instance, seq, input, fn)

Undocumented

Method	`__await__`	Support await.
Method	`__init__`	Undocumented
Method	`__repr__`	Undocumented
Method	`cancel`	Request cancellation of the operation.
Property	`operation_token`	The operation token for this handle.
Method	`_apply_cancel_command`	Undocumented
Method	`_apply_schedule_command`	Undocumented
Method	`_resolve_failure`	Undocumented
Method	`_resolve_start_success`	Undocumented
Method	`_resolve_success`	Undocumented
Instance Variable	`_input`	Undocumented
Instance Variable	`_instance`	Undocumented
Instance Variable	`_result_fut`	Undocumented
Instance Variable	`_seq`	Undocumented
Instance Variable	`_start_fut`	Undocumented
Instance Variable	`_task`	Undocumented

def __await__(self) -> Generator[Any, Any, OutputT]: (source) ¶

overrides temporalio.workflow.NexusOperationHandle.__await__

Support await.

def __init__(self, instance: _WorkflowInstanceImpl, seq: int, input: StartNexusOperationInput[Any, OutputT], fn: Coroutine[Any, Any, OutputT]): (source) ¶

Undocumented

def __repr__(self) -> str: (source) ¶

Undocumented

def cancel(self) -> bool: (source) ¶

overrides temporalio.workflow.NexusOperationHandle.cancel

Request cancellation of the operation.

@property
operation_token: str | None = (source) ¶

overrides temporalio.workflow.NexusOperationHandle.operation_token

The operation token for this handle.

def _apply_cancel_command(self, command: temporalio.bridge.proto.workflow_commands.WorkflowCommand): (source) ¶

Undocumented

def _apply_schedule_command(self): (source) ¶