astronomer.providers.amazon.aws.sensors.redshift_cluster

Module Contents

Classes

RedshiftClusterSensorAsync

Waits for a Redshift cluster to reach a specific status.

class astronomer.providers.amazon.aws.sensors.redshift_cluster.RedshiftClusterSensorAsync(*, poll_interval=5, **kwargs)

Bases: airflow.providers.amazon.aws.sensors.redshift_cluster.RedshiftClusterSensor

Waits for a Redshift cluster to reach a specific status.

Parameters:

cluster_identifier – The identifier for the cluster being pinged. :param target_status: The cluster status desired.

execute(context)

Check for the target_status and defers using the trigger

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.