From 08879a404f0323b23c8247ee6f13794885935e2f Mon Sep 17 00:00:00 2001 From: Raunak Bhagat Date: Thu, 19 Dec 2024 10:10:15 -0800 Subject: [PATCH] Update printout of wrapper --- tools/tpcds.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/tools/tpcds.py b/tools/tpcds.py index e645cae337..6bab9cc4bd 100644 --- a/tools/tpcds.py +++ b/tools/tpcds.py @@ -31,7 +31,7 @@ def dispatch(workflow: Workflow, branch_name: str, inputs: dict) -> WorkflowRun: pre_creation_latest_run = get_latest_run(workflow) - print(f"Launching workflow '{workflow.name}' on the branch '{branch_name}' with the inputs '{inputs}'") + print(f"Launching workflow '{workflow.name}' on the branch '{branch_name}'") created = workflow.create_dispatch( ref=branch_name, inputs=inputs, @@ -51,7 +51,7 @@ def dispatch(workflow: Workflow, branch_name: str, inputs: dict) -> WorkflowRun: "Run numbers are always returned in sorted order and are always monotonically increasing" ) if not post_creation_latest_run: - raise RuntimeError("Unable to locate the new run request for the 'build-commit' workflow") + raise RuntimeError(f"Unable to locate the new run request for the '{workflow.name}' workflow") print(f"Launched new '{workflow.name}' workflow with id: {post_creation_latest_run.id}") print(f"View the workflow run at: {post_creation_latest_run.html_url}") @@ -138,6 +138,7 @@ def run( exit(1) expanded_questions = parse_questions(questions) + print(f"Running scale-factor of {scale_factor}GB on questions: {', '.join(map(str, expanded_questions))}") args_as_list = [f"--question={q} --scale-factor={scale_factor}" for q in expanded_questions] entrypoint_args = json.dumps(args_as_list)