DbtCloudRunJobTrigger

dbt Cloud

DbtCloudRunJobTrigger is triggered with run id and account id, makes async Http call to dbt and get the status for the submitted job with run id in polling interval of time.

View on GitHub

Last Updated: Jan. 23, 2023

Access Instructions

Install the dbt Cloud provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.

Parameters

conn_idThe connection identifier for connecting to Dbt.
run_idThe ID of a dbt Cloud job.
end_timeTime in seconds to wait for a job run to reach a terminal status. Defaults to 7 days.
account_idThe ID of a dbt Cloud account.
poll_intervalpolling period in seconds to check for the status.

Documentation

DbtCloudRunJobTrigger is triggered with run id and account id, makes async Http call to dbt and get the status for the submitted job with run id in polling interval of time.

Was this page helpful?