Respond to upstream: top-level start_workflow function

Author: dandavison

hello_nexus/basic/handler/service_handler.py

@@ -23,7 +23,7 @@
 from temporalio.nexus.handler import (
     WorkflowOperationToken,
     WorkflowRunOperationHandler,
-    temporal_operation_context,
+    start_workflow,
 )
 
 from hello_nexus.basic.handler.db_client import MyDBClient
@@ -58,8 +58,7 @@ async def start(
             ctx: StartOperationContext, input: MyInput
         ) -> WorkflowOperationToken[MyOutput]:
             # You could use self.connected_db_client here.
-            tctx = temporal_operation_context.get()
-            return await tctx.start_workflow(
+            return await start_workflow(
                 WorkflowStartedByNexusOperation.run,
                 input,
                 id=str(uuid.uuid4()),

hello_nexus/basic/handler/service_handler_with_operation_handler_classes.py

@@ -34,7 +34,7 @@ class directly.
 )
 from temporalio.nexus.handler import (
     cancel_operation,
-    temporal_operation_context,
+    start_workflow,
 )
 
 from hello_nexus.basic.handler.db_client import MyDBClient
@@ -130,8 +130,7 @@ class MyWorkflowRunOperation(OperationHandler[MyInput, MyOutput]):
     async def start(
         self, ctx: StartOperationContext, input: MyInput
     ) -> StartOperationResultAsync:
-        tctx = temporal_operation_context.get()
-        token = await tctx.start_workflow(
+        token = await start_workflow(
             WorkflowStartedByNexusOperation.run,
             input,
             id=str(uuid.uuid4()),

hello_nexus/without_service_definition/app.py

@@ -20,7 +20,7 @@
 from temporalio.nexus.handler import (
     WorkflowOperationToken,
     WorkflowRunOperationHandler,
-    temporal_operation_context,
+    start_workflow,
 )
 from temporalio.worker import UnsandboxedWorkflowRunner, Worker
 from temporalio.workflow import NexusClient
@@ -57,8 +57,7 @@ def my_workflow_run_operation(
         async def start(
             ctx: StartOperationContext, name: str
         ) -> WorkflowOperationToken[str]:
-            tctx = temporal_operation_context.get()
-            return await tctx.start_workflow(
+            return await start_workflow(
                 HandlerWorkflow.run,
                 name,
                 id=str(uuid.uuid4()),