airflow.providers.dbt.cloud.triggers.dbt
¶
Module Contents¶
Classes¶
DbtCloudRunJobTrigger is triggered with run id and account id, makes async Http call to dbt and |
- class airflow.providers.dbt.cloud.triggers.dbt.DbtCloudRunJobTrigger(conn_id, run_id, end_time, poll_interval, account_id)[source]¶
Bases:
airflow.triggers.base.BaseTrigger
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.
- Parameters
conn_id (str) – The connection identifier for connecting to Dbt.
run_id (int) – The ID of a dbt Cloud job.
end_time (float) – Time in seconds to wait for a job run to reach a terminal status. Defaults to 7 days.
account_id (int | None) – The ID of a dbt Cloud account.
poll_interval (float) – polling period in seconds to check for the status.