Don't print in workflow

Author: dandavison

nexus_sync_operations/caller/app.py

@@ -24,11 +24,13 @@ async def execute_caller_workflow(
         task_queue=TASK_QUEUE,
         workflows=[CallerWorkflow],
     ):
-        await client.execute_workflow(
+        log = await client.execute_workflow(
             CallerWorkflow.run,
             id=str(uuid.uuid4()),
             task_queue=TASK_QUEUE,
         )
+        for line in log:
+            print(line)
 
 
 if __name__ == "__main__":

nexus_sync_operations/caller/workflows.py

@@ -17,7 +17,8 @@
 @workflow.defn
 class CallerWorkflow:
     @workflow.run
-    async def run(self) -> None:
+    async def run(self) -> list[str]:
+        log = []
         nexus_client = workflow.create_nexus_client(
             service=GreetingService,
             endpoint=NEXUS_ENDPOINT,
@@ -27,7 +28,7 @@ async def run(self) -> None:
         supported_languages = await nexus_client.execute_operation(
             GreetingService.get_languages, GetLanguagesInput(include_unsupported=False)
         )
-        print(f"supported languages: {supported_languages}")
+        log.append(f"supported languages: {supported_languages}")
 
         # Set language
         previous_language = await nexus_client.execute_operation(
@@ -38,4 +39,8 @@ async def run(self) -> None:
             await nexus_client.execute_operation(GreetingService.get_language, None)
             == Language.ARABIC
         )
-        print(f"language changed: {previous_language.name} -> {Language.ARABIC.name}")
+        log.append(
+            f"language changed: {previous_language.name} -> {Language.ARABIC.name}"
+        )
+
+        return log