DEV

Author: dandavison

tests/helpers/worker.py

@@ -92,6 +92,7 @@ class KSExecuteActivityAction:
 class KitchenSinkWorkflow:
     @workflow.run
     async def run(self, params: KSWorkflowParams) -> Any:
+        print("🌈 in workflow")
         # Handle all initial actions
         for action in params.actions or []:
             should_return, ret = await self.handle_action(params, action)
@@ -111,6 +112,7 @@ async def run(self, params: KSWorkflowParams) -> Any:
     async def handle_action(
         self, params: KSWorkflowParams, action: KSAction
     ) -> Tuple[bool, Any]:
+        print("🌈 in handle_action")
         if action.result:
             if action.result.run_id:
                 return (True, workflow.info().run_id)

tests/worker/test_activity.py

@@ -56,8 +56,10 @@
 
 
 async def test_activity_hello(client: Client, worker: ExternalWorker):
+    print("🌈")
     @activity.defn
     async def say_hello(name: str) -> str:
+        print("🌈 in activity")
         return f"Hello, {name}!"
 
     result = await _execute_workflow_with_activity(
@@ -1309,6 +1311,7 @@ async def _execute_workflow_with_activity(
         worker_config["max_concurrent_activities"] = default_max_concurrent_activities
     async with Worker(**worker_config):
         try:
+            print("🌈 in client")
             handle = await client.start_workflow(
                 "kitchen_sink",
                 KSWorkflowParams(