Skip to content

Commit

Permalink
Update printout of wrapper
Browse files Browse the repository at this point in the history
  • Loading branch information
raunakab committed Dec 19, 2024
1 parent 49638f2 commit 08879a4
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions tools/tpcds.py
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand All @@ -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}")
Expand Down Expand Up @@ -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)

Expand Down

0 comments on commit 08879a4

Please sign in to comment.