Cleanup

Author: dandavison

nexus_sync_operations/README.md

@@ -1,5 +1,7 @@
 This sample shows how to create a Nexus service that is backed by a long-running workflow and
-exposes operations that use signals, queries, and updates against that workflow.
+exposes operations that execute updates and queries against that workflow. The long-running
+workflow, and the updates/queries are private implementation detail of the nexus service: the caller
+does not know how the operations are implemented.
 
 ### Sample directory structure
 

nexus_sync_operations/caller/workflows.py

@@ -1,10 +1,12 @@
+"""
+This is a workflow that calls nexus operations. The caller does not have information about how these
+operations are implemented by the nexus service.
+"""
+
 from temporalio import workflow
 
 from message_passing.introduction import Language
-from message_passing.introduction.workflows import (
-    GetLanguagesInput,
-    SetLanguageInput,
-)
+from message_passing.introduction.workflows import GetLanguagesInput, SetLanguageInput
 
 with workflow.unsafe.imports_passed_through():
     from nexus_sync_operations.service import GreetingService

nexus_sync_operations/endpoint_description.md

@@ -2,5 +2,3 @@
 - operation: `get_languages`
 - operation: `get_language`
 - operation: `set_language`
-- operation: `set_language_using_activity`
-- operation: `approve`

nexus_sync_operations/handler/service_handler.py

@@ -1,7 +1,6 @@
 """
-This file demonstrates how to implement a Nexus service that is backed by a long-running
-workflow and exposes operations that perform signals, updates, and queries against that
-workflow.
+This file demonstrates how to implement a Nexus service that is backed by a long-running workflow
+and exposes operations that perform updates, and queries against that workflow.
 """
 
 from __future__ import annotations
@@ -31,19 +30,16 @@ def __init__(
     async def create(cls, client: Client, task_queue: str) -> GreetingServiceHandler:
         # Obtain a workflow handle to the long-running workflow that backs this service, starting
         # the workflow if it is not already running.
-        return cls(await cls._get_workflow_handle(client, task_queue))
-
-    @staticmethod
-    async def _get_workflow_handle(
-        client: Client, task_queue: str
-    ) -> WorkflowHandle[GreetingWorkflow, str]:
-        return await client.start_workflow(
+        wf_handle = await client.start_workflow(
             GreetingWorkflow.run,
             id="nexus-sync-operations-greeting-workflow",
             task_queue=task_queue,
             id_conflict_policy=WorkflowIDConflictPolicy.USE_EXISTING,
         )
+        return cls(wf_handle)
 
+    # 👉 This is a handler for a nexus operation whose internal implementation involves executing a
+    # query against a long-running workflow that is private to the nexus service.
     @nexusrpc.handler.sync_operation
     async def get_languages(
         self, ctx: nexusrpc.handler.StartOperationContext, input: GetLanguagesInput
@@ -52,12 +48,16 @@ async def get_languages(
             GreetingWorkflow.get_languages, input
         )
 
+    # 👉 This is a handler for a nexus operation whose internal implementation involves executing a
+    # query against a long-running workflow that is private to the nexus service.
     @nexusrpc.handler.sync_operation
     async def get_language(
         self, ctx: nexusrpc.handler.StartOperationContext, input: None
     ) -> Language:
         return await self.greeting_workflow_handle.query(GreetingWorkflow.get_language)
 
+    # 👉 This is a handler for a nexus operation whose internal implementation involves executing an
+    # update against a long-running workflow that is private to the nexus service.
     @nexusrpc.handler.sync_operation
     async def set_language(
         self,

nexus_sync_operations/handler/worker.py

@@ -3,6 +3,7 @@
 from typing import Optional
 
 from temporalio.client import Client
+from temporalio.common import WorkflowIDConflictPolicy
 from temporalio.worker import Worker
 
 from message_passing.introduction.activities import call_greeting_service
@@ -22,18 +23,29 @@ async def main(client: Optional[Client] = None):
         "localhost:7233",
         namespace=NAMESPACE,
     )
-    greeting_service_handler = await GreetingServiceHandler.create(client, TASK_QUEUE)
 
     async with Worker(
         client,
         task_queue=TASK_QUEUE,
         workflows=[GreetingWorkflow],
         activities=[call_greeting_service],
-        nexus_service_handlers=[greeting_service_handler],
     ):
-        logging.info("Worker started, ctrl+c to exit")
-        await interrupt_event.wait()
-        logging.info("Shutting down")
+        long_running_workflow_handle = await client.start_workflow(
+            GreetingWorkflow.run,
+            id="nexus-sync-operations-greeting-workflow",
+            task_queue=TASK_QUEUE,
+            id_conflict_policy=WorkflowIDConflictPolicy.USE_EXISTING,
+        )
+        async with Worker(
+            client,
+            task_queue=TASK_QUEUE,
+            nexus_service_handlers=[
+                GreetingServiceHandler(long_running_workflow_handle)
+            ],
+        ):
+            logging.info("Worker started, ctrl+c to exit")
+            await interrupt_event.wait()
+            logging.info("Shutting down")
 
 
 if __name__ == "__main__":

nexus_sync_operations/service.py

@@ -1,10 +1,16 @@
+"""
+This module defines a Nexus service that exposes three operations.
+
+It is used by the nexus service handler to validate that the operation handlers implement the
+correct input and output types, and by the caller workflow to create a type-safe client. It does not
+contain the implementation of the operations; see nexus_sync_operations.handler.service_handler for
+that.
+"""
+
 import nexusrpc
 
 from message_passing.introduction import Language
-from message_passing.introduction.workflows import (
-    GetLanguagesInput,
-    SetLanguageInput,
-)
+from message_passing.introduction.workflows import GetLanguagesInput, SetLanguageInput
 
 
 @nexusrpc.service