Cleanup

Author: dandavison

hello_nexus/basic/handler/service_handler.py

@@ -1,12 +1,5 @@
 """
-This file demonstrates how to define operation handlers by using a "shorthand" style in
-which you implement the `start` method only. WorkflowRunOperationHandler implements
-`cancel` for you automatically, but apart from that, the other operation methods
-(`fetch_info`, `fetch_result`, and `cancel` for SyncOperationHandler) are all
-automatically created with "raise NotImplementedError" implementations.
-
-See hello_nexus/basic/handler/service_handler_with_operation_handler_classes.py for the
-alternative "fully manual" style where you implement an OperationHandler class directly.
+This file demonstrates how to implement a Nexus service.
 """
 
 from __future__ import annotations
@@ -55,10 +48,6 @@ async def my_workflow_run_operation(
     # that unlike the workflow run operation above, in this case the `start` method
     # returns the final operation result.
     #
-    # Here it is implemented using SyncOperationHandler.from_callable.
-    # See service_handler_with_operation_handler_classes.py for an alternative style
-    # involving subclassing SyncOperationHandler and overriding the start method.
-    #
     # Sync operations are free to make arbitrary network calls, or perform CPU-bound
     # computations. Total execution duration must not exceed 10s.
     @sync_operation

hello_nexus/basic/handler/workflows.py

@@ -3,12 +3,9 @@
 from hello_nexus.basic.service import MyInput, MyOutput
 
 
+# This is the workflow that is started by the `my_workflow_run_operation` nexus operation.
 @workflow.defn
 class WorkflowStartedByNexusOperation:
-    """
-    This is the workflow that is started by the `my_workflow_run_operation` nexus operation.
-    """
-
     @workflow.run
     async def run(self, input: MyInput) -> MyOutput:
         return MyOutput(message=f"Hello {input.name} from workflow run operation!")

hello_nexus/without_service_definition/app.py

@@ -40,10 +40,9 @@ async def run(self, message: str) -> str:
 @service_handler
 class MyNexusService:
     # Here we implement a Nexus operation backed by a Temporal workflow. The start
-    # method must use TemporalOperationContext.start_workflow to start the workflow,
-    # which returns a WorkflowOperationToken. (Temporal server will then take care of
-    # delivering the workflow result to the caller, using the Nexus RPC callback
-    # mechanism).
+    # method must use nexus.start_workflow to start the workflow. (Temporal server will
+    # then take care of delivering the workflow result to the caller, using the Nexus
+    # RPC callback mechanism).
     @workflow_run_operation
     async def my_workflow_run_operation(
         self, ctx: StartOperationContext, name: str