airflow.providers.dbt.cloud.sensors.dbt

Module Contents

Classes

DbtCloudJobRunSensor

Checks the status of a dbt Cloud job run.
class airflow.providers.dbt.cloud.sensors.dbt.DbtCloudJobRunSensor(*, dbt_cloud_conn_id=DbtCloudHook.default_conn_name, run_id, account_id=None, **kwargs)[source]

Bases: airflow.sensors.base.BaseSensorOperator

Checks the status of a dbt Cloud job run.

See also

For more information on how to use this sensor, take a look at the guide: Poll for status of a dbt Cloud Job run

Parameters

  • dbt_cloud_conn_id (str) -- The connection identifier for connecting to dbt Cloud.

  • run_id (int) -- The job run identifier.

  • account_id (Optional[int]) -- The dbt Cloud account identifier.

template_fields = ['dbt_cloud_conn_id', 'run_id', 'account_id'][source]
poke(self, context)[source]

Function that the sensors defined while deriving this class should override.

Was this entry helpful?