Polish Ch 5 TODO 8: pre-wire executor scaffolding in compliance worker

exercises/05_async_operations/README.md

@@ -58,18 +58,12 @@ While you are in the file, delete the now-unused `from compliance.activities imp
 
 ## Part C: Register the workflow + activity on the Compliance worker (TODO 8)
 
-Open `compliance/worker.py`. The Ch 3/4 worker only registered the Nexus handler. Now that the handler starts a workflow and that workflow runs an activity, register both:
+Open `compliance/worker.py`. The `with concurrent.futures.ThreadPoolExecutor(...) as executor:` block, the prints, and `await worker.run()` are already in place. Find the TODO 8 comment and add three arguments to the existing `Worker(...)` call, alongside `task_queue` and `nexus_service_handlers`:
 
 ```python
-with concurrent.futures.ThreadPoolExecutor(max_workers=100) as executor:
-    worker = Worker(
-        client,
-        task_queue=TASK_QUEUE,
-        workflows=[ComplianceWorkflow],
-        activities=[check_compliance],
-        activity_executor=executor,
-        nexus_service_handlers=[ComplianceNexusServiceHandler()],
-    )
+workflows=[ComplianceWorkflow],
+activities=[check_compliance],
+activity_executor=executor,
 ```
 
 The activity is registered as a plain `def` in `compliance/activities.py` (no `async`), so the worker needs an `activity_executor` to run it on a thread. We use a `ThreadPoolExecutor` here, the same pattern the Payments worker uses for its sync activities.

exercises/05_async_operations/exercise/compliance/worker.py

@@ -1,30 +1,34 @@
 import asyncio
+import concurrent.futures
 
 from temporalio.client import Client
 from temporalio.worker import Worker
 
+from compliance.activities import check_compliance
 from compliance.models import TASK_QUEUE
 from compliance.service_handler import ComplianceNexusServiceHandler
+from compliance.workflows import ComplianceWorkflow
 
 NAMESPACE = "compliance-namespace"
 
 async def main() -> None:
     """Compliance team's worker - hosts ComplianceWorkflow + check_compliance activity + Nexus handler."""
     client = await Client.connect("localhost:7233", namespace=NAMESPACE)
 
-    # TODO 8: Register ComplianceWorkflow and the check_compliance activity on this
-    # Worker alongside the existing Nexus service handler, and supply an executor for
-    # the sync activity. See the assignment for the wrapping pattern.
-    worker = Worker(
-        client,
-        task_queue=TASK_QUEUE,
-        nexus_service_handlers=[ComplianceNexusServiceHandler()],
-    )
-    print("=========================================================")
-    print(f"  Compliance Worker started on: {TASK_QUEUE}")
-    print(f"  Namespace: {NAMESPACE}")
-    print("=========================================================")
-    await worker.run()
+    with concurrent.futures.ThreadPoolExecutor(max_workers=100) as executor:
+        # TODO 8: Add three arguments to this Worker(...) call so it registers
+        # ComplianceWorkflow, the check_compliance activity, and the executor
+        # that runs the sync activity. See the assignment for the exact lines.
+        worker = Worker(
+            client,
+            task_queue=TASK_QUEUE,
+            nexus_service_handlers=[ComplianceNexusServiceHandler()],
+        )
+        print("=========================================================")
+        print(f"  Compliance Worker started on: {TASK_QUEUE}")
+        print(f"  Namespace: {NAMESPACE}")
+        print("=========================================================")
+        await worker.run()
 
 if __name__ == "__main__":
     asyncio.run(main())