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

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


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

Classes
~~~~~~~

.. autoapisummary::

   astronomer.providers.amazon.aws.operators.redshift_data.RedshiftDataOperatorAsync




.. py:class:: RedshiftDataOperatorAsync(*, poll_interval = 5, **kwargs)

   Bases: :py:obj:`airflow.providers.amazon.aws.operators.redshift_data.RedshiftDataOperator`

   Executes SQL Statements against an Amazon Redshift cluster.
   If there are multiple queries as part of the SQL, and one of them fails to reach a successful completion state,
   the operator returns the relevant error for the failed query.

   :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 aws_conn_id: AWS 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, executes the query and gets back the list of query_ids and
      defers trigger to poll for the status for the queries 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.