temporalio.nexus._operation_handlers.WorkflowRunOperationHandler

class documentation

class WorkflowRunOperationHandler(OperationHandler[InputT, OutputT]): (source)

Constructor: WorkflowRunOperationHandler(start, input_type, output_type)

View In Hierarchy

Operation handler for Nexus operations that start a workflow.

Use this class to create an operation handler that starts a workflow by passing your start method to the constructor. Your start method must use temporalio.nexus.WorkflowRunOperationContext.start_workflow to start the workflow.

Method __init__ Initialize the workflow run operation handler.
Async Method cancel Cancel the operation, by cancelling the workflow.
Async Method fetch_info Fetch operation info (not supported for Temporal Nexus operations).
Async Method fetch_result Fetch operation result (not supported for Temporal Nexus operations).
Async Method start Start the operation, by starting a workflow and completing asynchronously.
Instance Variable _input_type Undocumented
Instance Variable _output_type Undocumented
Instance Variable _start Undocumented
def __init__(self, start: Callable[[StartOperationContext, InputT], Awaitable[WorkflowHandle[OutputT]]], input_type: type[InputT] | None, output_type: type[OutputT] | None): (source)

Initialize the workflow run operation handler.

async def cancel(self, ctx: CancelOperationContext, token: str): (source)

Cancel the operation, by cancelling the workflow.

async def fetch_info(self, ctx: FetchOperationInfoContext, token: str) -> OperationInfo: (source)

Fetch operation info (not supported for Temporal Nexus operations).

async def fetch_result(self, ctx: FetchOperationResultContext, token: str) -> OutputT: (source)

Fetch operation result (not supported for Temporal Nexus operations).

async def start(self, ctx: StartOperationContext, input: InputT) -> StartOperationResultAsync: (source)

Start the operation, by starting a workflow and completing asynchronously.

_input_type = (source)

Undocumented

_output_type = (source)

Undocumented

_start = (source)

Undocumented