prefect-dbtcloud

from prefect import flow
from prefect_dbtcloud.tasks import run_job


@flow
def trigger_dbt_cloud_job_run():
    run_job(
        cause="<the motivation to run the job>",
        account_id="<your dbt Cloud Account ID>",
        job_id="<the identifier of the job to run>",
        token="<your dbt Cloud API token>",
        wait_for_job_run_completion=True,
    )

    trigger_dbt_cloud_job_run()

Dict

mkdocs

: