Rename: workflow_run_operation

dandavison · dandavison · commit 2fc971fc9e9e · 2025-04-28T18:02:04.000-04:00
diff --git a/temporalio/nexus/handler.py b/temporalio/nexus/handler.py
@@ -306,7 +306,7 @@ async def fetch_info(
 
 
 # TODO(dan): support overriding op name
-def workflow_operation(
+def workflow_run_operation(
     start_method: Callable[
         [S, I, nexusrpc.handler.StartOperationOptions],
         Awaitable[StartWorkflowOperationResult[O]],
diff --git a/tests/worker/test_nexus.py b/tests/worker/test_nexus.py
@@ -158,7 +158,7 @@ async def my_sync_operation(
             start_options_received_by_handler=options,
         )
 
-    @temporalio.nexus.handler.workflow_operation
+    @temporalio.nexus.handler.workflow_run_operation
     async def my_async_operation(
         self, input: MyInput, options: nexusrpc.handler.StartOperationOptions
     ) -> temporalio.nexus.handler.StartWorkflowOperationResult[MyOutput]:

Original file line number	Diff line number	Diff line change
`@@ -158,7 +158,7 @@ async def my_sync_operation(`
`158`	`158`	`start_options_received_by_handler=options,`
`159`	`159`	`)`
`160`	`160`
`161`		`- @temporalio.nexus.handler.workflow_operation`
	`161`	`+ @temporalio.nexus.handler.workflow_run_operation`
`162`	`162`	`async def my_async_operation(`
`163`	`163`	`self, input: MyInput, options: nexusrpc.handler.StartOperationOptions`
`164`	`164`	`) -> temporalio.nexus.handler.StartWorkflowOperationResult[MyOutput]:`