dbt Cloud Operator Async¶
To execute a dbt cloud job asynchronously and poll for status using Triggerer
DbtCloudRunJobOperatorAsync
.
trigger_dbt_job_run_async = DbtCloudRunJobOperatorAsync(
task_id="trigger_dbt_job_run_async",
job_id=DBT_CLOUD_JOB_ID,
check_interval=10,
timeout=300,
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/dbt/cloud/example_dags/example_dbt_cloud.py