in functions/data-processing-engines/dataform-tag-executor/main.py [0:0]
def run_repo_or_get_status(job_id: str, gcp_project: str, location: str, repo_name: str, tags: list, branch: str,
query_variables: dict):
if job_id:
return get_workflow_state(job_id)
else:
return run_workflow(gcp_project, location, repo_name, tags, True, branch, query_variables)