:py:mod:`astronomer.providers.amazon.aws.hooks.redshift_cluster`
================================================================

.. py:module:: astronomer.providers.amazon.aws.hooks.redshift_cluster


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

Classes
~~~~~~~

.. autoapisummary::

   astronomer.providers.amazon.aws.hooks.redshift_cluster.RedshiftHookAsync




.. py:class:: RedshiftHookAsync(*args, **kwargs)

   Bases: :py:obj:`astronomer.providers.amazon.aws.hooks.base_aws.AwsBaseHookAsync`

   Interact with AWS Redshift using aiobotocore python library

   .. py:method:: cluster_status(cluster_identifier, delete_operation = False)
      :async:

      Connects to the AWS redshift cluster via aiobotocore and get the status
      and returns the status of the cluster based on the cluster_identifier passed

      :param cluster_identifier: unique identifier of a cluster
      :param delete_operation: whether the method has been called as part of delete cluster operation


   .. py:method:: delete_cluster(cluster_identifier, skip_final_cluster_snapshot = True, final_cluster_snapshot_identifier = None, polling_period_seconds = 5.0)
      :async:

      Connects to the AWS redshift cluster via aiobotocore and
      deletes the cluster based on the cluster_identifier passed

      :param cluster_identifier: unique identifier of a cluster
      :param skip_final_cluster_snapshot: determines cluster snapshot creation
      :param final_cluster_snapshot_identifier: name of final cluster snapshot
      :param polling_period_seconds: polling period in seconds to check for the status


   .. py:method:: pause_cluster(cluster_identifier, polling_period_seconds = 5.0)
      :async:

      Connects to the AWS redshift cluster via aiobotocore and
      pause the cluster based on the cluster_identifier passed

      :param cluster_identifier: unique identifier of a cluster
      :param polling_period_seconds: polling period in seconds to check for the status


   .. py:method:: resume_cluster(cluster_identifier, polling_period_seconds = 5.0)
      :async:

      Connects to the AWS redshift cluster via aiobotocore and
      resume the cluster for the cluster_identifier passed

      :param cluster_identifier: unique identifier of a cluster
      :param polling_period_seconds: polling period in seconds to check for the status


   .. py:method:: get_cluster_status(cluster_identifier, expected_state, flag, delete_operation = False)
      :async:

      Make call self.cluster_status to know the status and run till the expected_state is met and set the flag

      :param cluster_identifier: unique identifier of a cluster
      :param expected_state: expected_state example("available", "pausing", "paused"")
      :param flag: asyncio even flag set true if success and if any error
      :param delete_operation: whether the method has been called as part of delete cluster operation