def run_repo_or_get_status()

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)