From fb3e91639f575d58d9bdbdeb5ee817dd5db3d8ae Mon Sep 17 00:00:00 2001 From: joshvanl Date: Fri, 16 Jan 2026 19:30:41 +0000 Subject: [PATCH] Workflow: remove sleeps from example Remove arbitrary sleeps from workflow examples Signed-off-by: joshvanl --- examples/workflow/child_workflow.py | 4 +--- examples/workflow/cross-app1.py | 4 +--- examples/workflow/cross-app2.py | 2 +- examples/workflow/cross-app3.py | 2 +- examples/workflow/fan_out_fan_in.py | 1 - 5 files changed, 4 insertions(+), 9 deletions(-) diff --git a/examples/workflow/child_workflow.py b/examples/workflow/child_workflow.py index 57ab2fc3e..f434e2ea1 100644 --- a/examples/workflow/child_workflow.py +++ b/examples/workflow/child_workflow.py @@ -40,12 +40,10 @@ def child_workflow(ctx: wf.DaprWorkflowContext): if __name__ == '__main__': wfr.start() - time.sleep(10) # wait for workflow runtime to start wf_client = wf.DaprWorkflowClient() instance_id = wf_client.schedule_new_workflow(workflow=main_workflow) - # Wait for the workflow to complete - time.sleep(5) + wf_client.wait_for_workflow_completion(instance_id) wfr.shutdown() diff --git a/examples/workflow/cross-app1.py b/examples/workflow/cross-app1.py index 1ef7b48da..69f0c44c0 100644 --- a/examples/workflow/cross-app1.py +++ b/examples/workflow/cross-app1.py @@ -46,13 +46,11 @@ def app1_workflow(ctx: wf.DaprWorkflowContext): if __name__ == '__main__': wfr.start() - time.sleep(10) # wait for workflow runtime to start wf_client = wf.DaprWorkflowClient() print('app1 - triggering app1 workflow', flush=True) instance_id = wf_client.schedule_new_workflow(workflow=app1_workflow) - # Wait for the workflow to complete - time.sleep(7) + wf_client.wait_for_workflow_completion(instance_id) wfr.shutdown() diff --git a/examples/workflow/cross-app2.py b/examples/workflow/cross-app2.py index 2af65912c..7e97b58c0 100644 --- a/examples/workflow/cross-app2.py +++ b/examples/workflow/cross-app2.py @@ -46,5 +46,5 @@ def app2_workflow(ctx: wf.DaprWorkflowContext): if __name__ == '__main__': wfr.start() - time.sleep(15) # wait for workflow runtime to start + time.sleep(15) # Keep the workflow runtime running for a while to process workflows wfr.shutdown() diff --git a/examples/workflow/cross-app3.py b/examples/workflow/cross-app3.py index 4bcc158a0..6b72de7e4 100644 --- a/examples/workflow/cross-app3.py +++ b/examples/workflow/cross-app3.py @@ -29,5 +29,5 @@ def app3_activity(ctx: wf.DaprWorkflowContext) -> int: if __name__ == '__main__': wfr.start() - time.sleep(15) # wait for workflow runtime to start + time.sleep(15) # Keep the workflow runtime alive for a while to process requests wfr.shutdown() diff --git a/examples/workflow/fan_out_fan_in.py b/examples/workflow/fan_out_fan_in.py index f625ea287..9cd1ff6cb 100644 --- a/examples/workflow/fan_out_fan_in.py +++ b/examples/workflow/fan_out_fan_in.py @@ -55,7 +55,6 @@ def process_results(ctx, final_result: int): if __name__ == '__main__': wfr.start() - time.sleep(10) # wait for workflow runtime to start wf_client = wf.DaprWorkflowClient() instance_id = wf_client.schedule_new_workflow(workflow=batch_processing_workflow, input=10)