Redshift Operator Async

To delete an AWS Redshift cluster if cluster status is in available state RedshiftDeleteClusterOperatorAsync.

delete_redshift_cluster = RedshiftDeleteClusterOperatorAsync(
    task_id="delete_redshift_cluster",
    trigger_rule="all_done",
    cluster_identifier=REDSHIFT_CLUSTER_IDENTIFIER,
    aws_conn_id=AWS_CONN_ID,
    skip_final_cluster_snapshot=True,
    final_cluster_snapshot_identifier=None,
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/amazon/aws/example_dags/example_redshift_cluster_management.py

To pause an AWS Redshift cluster if cluster status is in available state RedshiftPauseClusterOperatorAsync.

pause_redshift_cluster = RedshiftPauseClusterOperatorAsync(
    task_id="pause_redshift_cluster",
    cluster_identifier=REDSHIFT_CLUSTER_IDENTIFIER,
    aws_conn_id=AWS_CONN_ID,
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/amazon/aws/example_dags/example_redshift_cluster_management.py

To resume a paused AWS Redshift cluster asynchronously RedshiftResumeClusterOperatorAsync.

resume_redshift_cluster = RedshiftResumeClusterOperatorAsync(
    task_id="resume_redshift_cluster",
    cluster_identifier=REDSHIFT_CLUSTER_IDENTIFIER,
    aws_conn_id=AWS_CONN_ID,
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/amazon/aws/example_dags/example_redshift_cluster_management.py