:py:mod:`astronomer.providers.core.triggers.astro`
==================================================

.. py:module:: astronomer.providers.core.triggers.astro


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

Classes
~~~~~~~

.. autoapisummary::

   astronomer.providers.core.triggers.astro.AstroDeploymentTrigger




.. py:class:: AstroDeploymentTrigger(external_dag_id, dag_run_id, external_task_id = None, astro_cloud_conn_id = 'astro_cloud_default', poke_interval = 5.0, **kwargs)


   Bases: :py:obj:`airflow.triggers.base.BaseTrigger`

   Custom Apache Airflow trigger for monitoring the completion status of an external deployment using Astro Cloud.

   :param external_dag_id: External ID of the DAG being monitored.
   :param dag_run_id: ID of the DAG run being monitored.
   :param external_task_id: External ID of the task being monitored. If None, monitors the entire DAG.
   :param astro_cloud_conn_id: The connection ID to retrieve Astro Cloud credentials. Defaults to "astro_cloud_default".
   :param poke_interval: Time in seconds to wait between consecutive checks for completion status.
   :param kwargs: Additional keyword arguments passed to the BaseTrigger constructor.

   .. py:method:: serialize()

      Serialize the trigger for storage in the database.


   .. py:method:: run()
      :async:

      Asynchronously runs the trigger and yields completion status events.

      Checks the status of the external deployment using Astro Cloud at regular intervals.
      Yields TriggerEvent with the status "done" if successful, "failed" if failed.