`astronomer.providers.dbt.cloud.sensors.dbt`¶

Module Contents¶

Checks the status of a dbt Cloud job run.

class astronomer.providers.dbt.cloud.sensors.dbt.DbtCloudJobRunSensorAsync(*, poll_interval=5, timeout=60 * 60 * 24 * 7, **kwargs)[source]¶

Checks the status of a dbt Cloud job run.

See also

For more information on sync Sensor DbtCloudJobRunSensor, take a look at the guide:: Poll for status of a dbt Cloud Job run

Parameters:

dbt_cloud_conn_id – The connection identifier for connecting to dbt Cloud.
run_id – The job run identifier.
account_id – The dbt Cloud account identifier.
timeout (float) – Time in seconds to wait for a job run to reach a terminal status. Defaults to 7 days.

execute(context)[source]¶

Defers trigger class to poll for state of the job run until it reaches a failure state or success state

execute_complete(context, event)[source]¶

Callback for when the trigger fires - returns immediately. Relies on trigger to throw an exception, otherwise it assumes execution was successful.