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

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


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

Classes
~~~~~~~

.. autoapisummary::

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




.. 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:method:: serialize()

      Serializes RedshiftSQLTrigger arguments and classpath.


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

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