Respond to upstream: rename decorators

Author: dandavison

hello_nexus/basic/handler/service_handler.py

@@ -13,13 +13,9 @@
 
 import uuid
 
-from nexusrpc.handler import (
-    StartOperationContext,
-    service_handler,
-    sync_operation_handler,
-)
+from nexusrpc.handler import StartOperationContext, service_handler, sync_operation
 from temporalio import nexus
-from temporalio.nexus import workflow_run_operation_handler
+from temporalio.nexus import workflow_run_operation
 
 from hello_nexus.basic.handler.db_client import MyDBClient
 from hello_nexus.basic.handler.workflows import WorkflowStartedByNexusOperation
@@ -44,7 +40,7 @@ def __init__(self, connected_db_client: MyDBClient):
     #
     # The token will be used by the caller if it subsequently wants to cancel the Nexus
     # operation.
-    @workflow_run_operation_handler
+    @workflow_run_operation
     async def my_workflow_run_operation(
         self, ctx: StartOperationContext, input: MyInput
     ) -> nexus.WorkflowHandle[MyOutput]:
@@ -65,7 +61,7 @@ async def my_workflow_run_operation(
     #
     # Sync operations are free to make arbitrary network calls, or perform CPU-bound
     # computations. Total execution duration must not exceed 10s.
-    @sync_operation_handler
+    @sync_operation
     async def my_sync_operation(
         self, ctx: StartOperationContext, input: MyInput
     ) -> MyOutput:

hello_nexus/without_service_definition/app.py

@@ -15,7 +15,7 @@
 )
 from temporalio import nexus, workflow
 from temporalio.client import Client
-from temporalio.nexus import workflow_run_operation_handler
+from temporalio.nexus import workflow_run_operation
 from temporalio.worker import UnsandboxedWorkflowRunner, Worker
 from temporalio.workflow import NexusClient
 
@@ -44,7 +44,7 @@ class MyNexusServiceHandler:
     # which returns a WorkflowOperationToken. (Temporal server will then take care of
     # delivering the workflow result to the caller, using the Nexus RPC callback
     # mechanism).
-    @workflow_run_operation_handler
+    @workflow_run_operation
     async def my_workflow_run_operation(
         self, ctx: StartOperationContext, name: str
     ) -> nexus.WorkflowHandle[str]: