airflow.providers.dbt.cloud.sensors.dbt

Module Contents

Classes

DbtCloudJobRunSensor

Checks the status of a dbt Cloud job run.

DbtCloudJobRunAsyncSensor

This class is deprecated.
class airflow.providers.dbt.cloud.sensors.dbt.DbtCloudJobRunSensor(*, dbt_cloud_conn_id=DbtCloudHook.default_conn_name, run_id, account_id=None, deferrable=False, **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 (int | None) – The dbt Cloud account identifier.

  • deferrable (bool) – Run sensor in the deferrable mode.

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

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

execute(context)[source]

Defers to 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.

class airflow.providers.dbt.cloud.sensors.dbt.DbtCloudJobRunAsyncSensor(**kwargs)[source]

Bases: DbtCloudJobRunSensor

This class is deprecated. Please use airflow.providers.dbt.cloud.sensor.dbt.DbtCloudJobRunSensor.

Was this entry helpful?