From 3512a556ee5ab2d37631ec40a20fe8cae7404bfe Mon Sep 17 00:00:00 2001 From: Keith Suderman Date: Thu, 1 Jun 2023 11:27:28 -0400 Subject: [PATCH] Change wait_for_invocation terminal states --- abm/lib/benchmark.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/abm/lib/benchmark.py b/abm/lib/benchmark.py index 7126101..b125c4e 100644 --- a/abm/lib/benchmark.py +++ b/abm/lib/benchmark.py @@ -161,7 +161,8 @@ def run(context: Context, workflow_path, history_prefix: str, experiment: str): new_history_name = f"{experiment} {new_history_name}" invocation = gi.workflows.invoke_workflow(wfid, inputs=inputs, history_name=new_history_name) id = invocation['id'] - invocations = gi.invocations.wait_for_invocation(id, 86400, 10, False) + #invocations = gi.invocations.wait_for_invocation(id, 86400, 10, False) + invocations = gi.invocations.wait_for_invocation(id, 86400, 10, True) print("Waiting for jobs") if history_prefix is not None: parts = history_prefix.split()