:py:mod:`astronomer.providers.amazon.aws.triggers.redshift_data`
================================================================

.. py:module:: astronomer.providers.amazon.aws.triggers.redshift_data


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

Classes
~~~~~~~

.. autoapisummary::

   astronomer.providers.amazon.aws.triggers.redshift_data.RedshiftDataTrigger




.. py:class:: RedshiftDataTrigger(task_id, poll_interval, query_ids, aws_conn_id = 'aws_default')

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

   RedshiftDataTrigger is fired as deferred class with params to run the task in triggerer.

   :param task_id: task ID of the Dag
   :param poll_interval:  polling period in seconds to check for the status
   :param aws_conn_id: AWS connection ID for redshift
   :param query_ids: list of query IDs to run and poll for the status

   .. py:method:: serialize()

      Serializes RedshiftDataTrigger arguments and classpath.


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

      Makes async connection and gets status for a list of queries submitted by the operator.
      Even if one of the queries has a non-successful state, the hook returns a failure event and the error
      is sent back to the operator.