dbt Cloud Sensor Async¶
To checks the status of a dbt job run asynchronously
DbtCloudJobRunSensorAsync
.
job_run_sensor_async = DbtCloudJobRunSensorAsync(
task_id="job_run_sensor_async", run_id=trigger_job_run2.output, timeout=20
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/dbt/cloud/example_dags/example_dbt_cloud.py