temporalio.nexus._operation_handlers.WorkflowRunOperationHandler

class documentation

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

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	`_start`	Undocumented

def __init__(self, start: Callable[[StartOperationContext, InputT], Awaitable[WorkflowHandle[OutputT]]]): (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.

Undocumented