:py:mod:`astronomer.providers.dbt.cloud.sensors.dbt`
====================================================

.. py:module:: astronomer.providers.dbt.cloud.sensors.dbt


Module Contents
---------------

Classes
~~~~~~~

.. autoapisummary::

   astronomer.providers.dbt.cloud.sensors.dbt.DbtCloudJobRunSensorAsync




.. py:class:: DbtCloudJobRunSensorAsync(*, poll_interval = 5, timeout = 60 * 60 * 24 * 7, **kwargs)

   Bases: :py:obj:`airflow.providers.dbt.cloud.sensors.dbt.DbtCloudJobRunSensor`

   Checks the status of a dbt Cloud job run.

   .. seealso::
       For more information on sync Sensor DbtCloudJobRunSensor, take a look at the guide::
       :ref:`howto/operator:DbtCloudJobRunSensor`

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

   .. py:method:: execute(context)

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


   .. py:method:: execute_complete(context, event)

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