astronomer.providers.amazon.aws.triggers.redshift_data
======================================================

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


Classes
-------

.. autoapisummary::

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


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

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

   This class is deprecated and will be removed in 2.0.0.
   Use :class: `~airflow.providers.amazon.aws.triggers.redshift_data.RedshiftDataTrigger` instead

   :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:attribute:: task_id


   .. py:attribute:: poll_interval


   .. py:attribute:: aws_conn_id


   .. py:attribute:: query_ids


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