astronomer.providers.amazon.aws.triggers.redshift_sql
=====================================================

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


Classes
-------

.. autoapisummary::

   astronomer.providers.amazon.aws.triggers.redshift_sql.RedshiftSQLTrigger


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

.. py:class:: RedshiftSQLTrigger(task_id, polling_period_seconds, aws_conn_id, query_ids)

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


   RedshiftSQLTrigger is fired as deferred class with params to run the task in trigger worker

   :param task_id: Reference to task id of the Dag
   :param polling_period_seconds:  polling period in seconds to check for the status
   :param aws_conn_id: Reference to 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:: polling_period_seconds


   .. py:attribute:: aws_conn_id


   .. py:attribute:: query_ids


   .. py:method:: serialize()

      Serializes RedshiftSQLTrigger arguments and classpath.



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


      Make async connection and execute query using the Amazon Redshift Data API.