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

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


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

Classes
~~~~~~~

.. autoapisummary::

   astronomer.providers.amazon.aws.operators.redshift_sql.RedshiftSQLOperatorAsync




.. py:class:: RedshiftSQLOperatorAsync(*, redshift_conn_id = 'redshift_default', poll_interval = 5, **kwargs)

   Bases: :py:obj:`airflow.providers.amazon.aws.operators.redshift_sql.RedshiftSQLOperator`

   Executes SQL Statements against an Amazon Redshift cluster"

   :param sql: the SQL code to be executed as a single string, or
       a list of str (sql statements), or a reference to a template file.
       Template references are recognized by str ending in '.sql'
   :param redshift_conn_id: reference to Amazon Redshift connection id
   :param parameters: (optional) the parameters to render the SQL query with.
   :param autocommit: if True, each command is automatically committed.
       (default value: False)

   .. py:method:: execute(context)

      Makes a sync call to RedshiftDataHook and execute the query and gets back the query_ids list and
      defers trigger to poll for the status for the query executed


   .. py:method:: execute_complete(context, event = None)

      Callback for when the trigger fires - returns immediately.
      Relies on trigger to throw an exception, otherwise it assumes execution was
      successful.