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

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


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

Classes
~~~~~~~

.. autoapisummary::

   astronomer.providers.dbt.cloud.operators.dbt.DbtCloudRunJobOperatorAsync




.. py:class:: DbtCloudRunJobOperatorAsync(*, dbt_cloud_conn_id = DbtCloudHook.default_conn_name, job_id, account_id = None, trigger_reason = None, steps_override = None, schema_override = None, wait_for_termination = True, timeout = 60 * 60 * 24 * 7, check_interval = 60, additional_run_config = None, deferrable = False, **kwargs)

   Bases: :py:obj:`airflow.providers.dbt.cloud.operators.dbt.DbtCloudRunJobOperator`

   Executes a dbt Cloud job asynchronously. Trigger the dbt cloud job via worker to dbt and with run id in response
   poll for the status in trigger.

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

   :param dbt_cloud_conn_id: The connection ID for connecting to dbt Cloud.
   :param job_id: The ID of a dbt Cloud job.
   :param account_id: Optional. The ID of a dbt Cloud account.
   :param trigger_reason: Optional Description of the reason to trigger the job. Dbt requires the trigger reason while
       making an API. if it is not provided uses the default reasons.
   :param steps_override: Optional. List of dbt commands to execute when triggering the job instead of those
       configured in dbt Cloud.
   :param schema_override: Optional. Override the destination schema in the configured target for this job.
   :param timeout: Time in seconds to wait for a job run to reach a terminal status. Defaults to 7 days.
   :param check_interval: Time in seconds to check on a job run's status. Defaults to 60 seconds.
   :param additional_run_config: Optional. Any additional parameters that should be included in the API
       request when triggering the job.
   :return: The ID of the triggered dbt Cloud job run.

   .. py:method:: execute(context)

      Submits a job which generates a run_id and gets deferred


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