Reorganize

Author: dandavison

hello_nexus/README.md

@@ -1,14 +1,37 @@
-# Nexus
+This sample shows how to define a Nexus service, implement the operation handlers, and
+call the operations from a workflow.
 
-Temporal Nexus is a feature of the Temporal platform designed to connect durable executions across team, namespace,
-region, and cloud boundaries. It promotes a more modular architecture for sharing a subset of your team’s capabilities
-via well-defined service API contracts for other teams to use. These can abstract underlying Temporal primitives such as
-Workflows, or execute arbitrary code.
+### Sample directory structure
 
-Learn more at [temporal.io/nexus](https://temporal.io/nexus).
+- [service.py](./service.py) - shared Nexus service definition
+- [caller](./caller) - a caller workflow that executes Nexus operations, together with a worker and starter code
+- [handler](./handler) - Nexus operation handlers, together with a workflow used by one of the Nexus operations, and a worker that polls for both workflow and Nexus tasks.
 
-The samples in this directory form an introduction to Nexus. 
 
-### Samples
+### Instructions
 
-- [basic](./basic) - Nexus service definition, operation handlers, and calling workflows.
+Start a Temporal server. (See the main samples repo [README](../README.md)).
+
+Run the following:
+
+```
+temporal operator namespace create --namespace hello-nexus-basic-handler-namespace
+temporal operator namespace create --namespace hello-nexus-basic-caller-namespace
+
+temporal operator nexus endpoint create \
+  --name hello-nexus-basic-nexus-endpoint \
+  --target-namespace hello-nexus-basic-handler-namespace \
+  --target-task-queue my-handler-task-queue \
+  --description-file endpoint_description.md
+```
+
+In one terminal, in this directory, run the Temporal worker in the handler namespace:
+```
+uv run handler/worker.py
+```
+
+In another terminal, in this directory, run the Temporal worker in the caller namespace and start the caller
+workflow:
+```
+uv run caller/app.py
+```

hello_nexus/basic/README.md

@@ -5,8 +5,8 @@
 from temporalio.client import Client
 from temporalio.worker import UnsandboxedWorkflowRunner, Worker
 
-from hello_nexus.basic.caller.workflows import CallerWorkflow
-from hello_nexus.basic.service import MyOutput
+from hello_nexus.caller.workflows import CallerWorkflow
+from hello_nexus.service import MyOutput
 
 NAMESPACE = "hello-nexus-basic-caller-namespace"
 TASK_QUEUE = "hello-nexus-basic-caller-task-queue"

hello_nexus/basic/handler/__init__.py

@@ -2,7 +2,7 @@
 from temporalio.workflow import NexusClient
 
 with workflow.unsafe.imports_passed_through():
-    from hello_nexus.basic.service import MyInput, MyNexusService, MyOutput
+    from hello_nexus.service import MyInput, MyNexusService, MyOutput
 
 NEXUS_ENDPOINT = "hello-nexus-basic-nexus-endpoint"
 

hello_nexus/basic/__init__.py hello_nexus/caller/__init__.pyhello_nexus/basic/__init__.py renamed to hello_nexus/caller/__init__.py

@@ -10,9 +10,9 @@
 from temporalio import nexus
 from temporalio.nexus import WorkflowRunOperationContext, workflow_run_operation
 
-from hello_nexus.basic.handler.db_client import MyDBClient
-from hello_nexus.basic.handler.workflows import WorkflowStartedByNexusOperation
-from hello_nexus.basic.service import MyInput, MyNexusService, MyOutput
+from hello_nexus.handler.db_client import MyDBClient
+from hello_nexus.handler.workflows import WorkflowStartedByNexusOperation
+from hello_nexus.service import MyInput, MyNexusService, MyOutput
 
 
 @service_handler(service=MyNexusService)