Don't demonstrate passing in a db client

Author: dandavison

hello_nexus/handler/db_client.py

@@ -10,7 +10,6 @@
 from temporalio import nexus
 from temporalio.nexus import WorkflowRunOperationContext, workflow_run_operation
 
-from hello_nexus.handler.db_client import MyDBClient
 from hello_nexus.handler.workflows import WorkflowStartedByNexusOperation
 from hello_nexus.service import MyInput, MyNexusService, MyOutput
 
@@ -20,11 +19,6 @@ class MyNexusServiceHandler:
     # You can create an __init__ method accepting what is needed by your operation
     # handlers to handle requests. You typically instantiate your service handler class
     # when starting your worker. See hello_nexus/basic/handler/worker.py.
-    def __init__(self, connected_db_client: MyDBClient):
-        # `connected_db_client` is intended as an example of something that might be
-        # required by your operation handlers when handling requests, but is only
-        # available at worker-start time.
-        self.connected_db_client = connected_db_client
 
     # This is a nexus operation that is backed by a Temporal workflow. The start method
     # starts a workflow, and returns a nexus operation token. Meanwhile, the workflow
@@ -37,7 +31,6 @@ def __init__(self, connected_db_client: MyDBClient):
     async def my_workflow_run_operation(
         self, ctx: WorkflowRunOperationContext, input: MyInput
     ) -> nexus.WorkflowHandle[MyOutput]:
-        # You could use self.connected_db_client here.
         return await ctx.start_workflow(
             WorkflowStartedByNexusOperation.run,
             input,
@@ -54,5 +47,4 @@ async def my_workflow_run_operation(
     async def my_sync_operation(
         self, ctx: StartOperationContext, input: MyInput
     ) -> MyOutput:
-        # You could use self.connected_db_client here.
         return MyOutput(message=f"Hello {input.name} from sync operation!")

hello_nexus/handler/service_handler.py

@@ -5,7 +5,6 @@
 from temporalio.client import Client
 from temporalio.worker import Worker
 
-from hello_nexus.handler.db_client import MyDBClient
 from hello_nexus.handler.service_handler import MyNexusServiceHandler
 from hello_nexus.handler.workflows import WorkflowStartedByNexusOperation
 
@@ -23,11 +22,6 @@ async def main(client: Optional[Client] = None):
         namespace=NAMESPACE,
     )
 
-    # Create an instance of the service handler. Your service handler class __init__ can
-    # be written to accept any arguments that your operation handlers need when handling
-    # requests. In this example we provide a database client object to the service hander.
-    connected_db_client = MyDBClient.connect()
-
     # Start the worker, passing the Nexus service handler instance, in addition to the
     # workflow classes that are started by your nexus operations, and any activities
     # needed. This Worker will poll for both workflow tasks and Nexus tasks (this example
@@ -36,9 +30,7 @@ async def main(client: Optional[Client] = None):
         client,
         task_queue=TASK_QUEUE,
         workflows=[WorkflowStartedByNexusOperation],
-        nexus_service_handlers=[
-            MyNexusServiceHandler(connected_db_client=connected_db_client)
-        ],
+        nexus_service_handlers=[MyNexusServiceHandler()],
     ):
         logging.info("Worker started, ctrl+c to exit")
         await interrupt_event.wait()