amazon.aws.operators.redshift_cluster

Module Contents

Classes

RedshiftResumeClusterOperatorAsync

Resume a paused AWS Redshift Cluster

RedshiftPauseClusterOperatorAsync

Pause an AWS Redshift Cluster if cluster status is in available state
class amazon.aws.operators.redshift_cluster.RedshiftResumeClusterOperatorAsync(*, poll_interval=5, **kwargs)

Bases: airflow.providers.amazon.aws.operators.redshift_cluster.RedshiftResumeClusterOperator

Resume a paused AWS Redshift Cluster

Parameters

  • cluster_identifier – id of the AWS Redshift Cluster

  • aws_conn_id – aws connection to use

execute(self, context)

Logic that the operator uses to correctly identify which trigger to execute, and defer execution as expected.

execute_complete(self, context, event=None)

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

class amazon.aws.operators.redshift_cluster.RedshiftPauseClusterOperatorAsync(*, poll_interval=5, **kwargs)

Bases: airflow.providers.amazon.aws.operators.redshift_cluster.RedshiftPauseClusterOperator

Pause an AWS Redshift Cluster if cluster status is in available state

Parameters

  • cluster_identifier – id of the AWS Redshift Cluster

  • aws_conn_id – aws connection to use

execute(self, context)

Logic that the operator uses to correctly identify which trigger to execute, and defer execution as expected.

execute_complete(self, context, event=None)

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