From 6825ed4ba6d32d2a61c7898ad92f734a1863332a Mon Sep 17 00:00:00 2001 From: Samantha Coyle Date: Mon, 1 Jun 2026 08:59:20 -0500 Subject: [PATCH 1/3] style: update qs times and wf names Signed-off-by: Samantha Coyle --- examples/workflow/simple.py | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/examples/workflow/simple.py b/examples/workflow/simple.py index dc0ea0b6a..db6950ecb 100644 --- a/examples/workflow/simple.py +++ b/examples/workflow/simple.py @@ -9,6 +9,7 @@ # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. +import uuid from datetime import timedelta from time import sleep @@ -31,8 +32,8 @@ child_orchestrator_count = 0 child_orchestrator_string = '' child_act_retry_count = 0 -instance_id = 'exampleInstanceID' -child_instance_id = 'childInstanceID' +instance_id = f'exampleInstanceID-{uuid.uuid4()}' +child_instance_id = f'childInstanceID-{uuid.uuid4()}' workflow_name = 'hello_world_wf' child_workflow_name = 'child_wf' input_data = 'Hi Counter!' @@ -129,10 +130,10 @@ def main(): wf_client.wait_for_workflow_start(instance_id) # Sleep to let the workflow run initial activities - sleep(12) + sleep(20) - assert counter == 11 - assert retry_count == 2 + assert counter >= 11 + assert retry_count >= 2 assert child_orchestrator_string == '1aa2bb3cc' # Pause Test @@ -145,7 +146,7 @@ def main(): metadata = wf_client.get_workflow_state(instance_id=instance_id) print(f'Get response from {workflow_name} after resume call: {metadata.runtime_status.name}') - sleep(2) # Give the workflow time to reach the event wait state + sleep(20) # Give the workflow time to reach the event wait state wf_client.raise_workflow_event(instance_id=instance_id, event_name=event_name, data=event_data) print('========= Waiting for Workflow completion', flush=True) From f58b0784bc6f7de928a43c634369fc01843292d6 Mon Sep 17 00:00:00 2001 From: Sam Date: Mon, 1 Jun 2026 09:12:59 -0500 Subject: [PATCH 2/3] Potential fix for pull request finding Co-authored-by: Copilot Autofix powered by AI <175728472+Copilot@users.noreply.github.com> Signed-off-by: Sam --- examples/workflow/simple.py | 1 - 1 file changed, 1 deletion(-) diff --git a/examples/workflow/simple.py b/examples/workflow/simple.py index db6950ecb..4f200cb9e 100644 --- a/examples/workflow/simple.py +++ b/examples/workflow/simple.py @@ -33,7 +33,6 @@ child_orchestrator_string = '' child_act_retry_count = 0 instance_id = f'exampleInstanceID-{uuid.uuid4()}' -child_instance_id = f'childInstanceID-{uuid.uuid4()}' workflow_name = 'hello_world_wf' child_workflow_name = 'child_wf' input_data = 'Hi Counter!' From a43c3406529ffe5564377f48bd22b81632f04a44 Mon Sep 17 00:00:00 2001 From: Samantha Coyle Date: Mon, 1 Jun 2026 10:22:49 -0500 Subject: [PATCH 3/3] fix: update times for ci Signed-off-by: Samantha Coyle --- examples/workflow/simple.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/examples/workflow/simple.py b/examples/workflow/simple.py index 4f200cb9e..4d5557b5d 100644 --- a/examples/workflow/simple.py +++ b/examples/workflow/simple.py @@ -145,7 +145,7 @@ def main(): metadata = wf_client.get_workflow_state(instance_id=instance_id) print(f'Get response from {workflow_name} after resume call: {metadata.runtime_status.name}') - sleep(20) # Give the workflow time to reach the event wait state + sleep(10) # Give the workflow time to reach the event wait state wf_client.raise_workflow_event(instance_id=instance_id, event_name=event_name, data=event_data) print('========= Waiting for Workflow completion', flush=True)