Redshift Sensor Async¶
To waits asynchronously for Redshift cluster to reach a specific status
RedshiftClusterSensorAsync
.
redshift_sensor = RedshiftClusterSensorAsync(
task_id="redshift_sensor",
cluster_identifier=REDSHIFT_CLUSTER_IDENTIFIER,
target_status="available",
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