airflow.providers.amazon.aws.triggers.redshift_cluster
¶
Module Contents¶
Classes¶
Trigger for RedshiftCreateClusterOperator. |
|
Trigger for RedshiftPauseClusterOperator. |
|
Trigger for RedshiftCreateClusterSnapshotOperator. |
|
Trigger for RedshiftResumeClusterOperator. |
|
Trigger for RedshiftDeleteClusterOperator. |
|
RedshiftClusterTrigger is fired as deferred class with params to run the task in trigger worker. |
- class airflow.providers.amazon.aws.triggers.redshift_cluster.RedshiftCreateClusterTrigger(cluster_identifier, aws_conn_id='aws_default', waiter_delay=15, waiter_max_attempts=999999)[source]¶
Bases:
airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger
Trigger for RedshiftCreateClusterOperator.
The trigger will asynchronously poll the boto3 API and wait for the Redshift cluster to be in the available state.
- Parameters
- class airflow.providers.amazon.aws.triggers.redshift_cluster.RedshiftPauseClusterTrigger(cluster_identifier, aws_conn_id='aws_default', waiter_delay=15, waiter_max_attempts=999999)[source]¶
Bases:
airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger
Trigger for RedshiftPauseClusterOperator.
The trigger will asynchronously poll the boto3 API and wait for the Redshift cluster to be in the paused state.
- Parameters
- class airflow.providers.amazon.aws.triggers.redshift_cluster.RedshiftCreateClusterSnapshotTrigger(cluster_identifier, aws_conn_id='aws_default', waiter_delay=15, waiter_max_attempts=999999)[source]¶
Bases:
airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger
Trigger for RedshiftCreateClusterSnapshotOperator.
The trigger will asynchronously poll the boto3 API and wait for the Redshift cluster snapshot to be in the available state.
- Parameters
- class airflow.providers.amazon.aws.triggers.redshift_cluster.RedshiftResumeClusterTrigger(cluster_identifier, aws_conn_id='aws_default', waiter_delay=15, waiter_max_attempts=999999)[source]¶
Bases:
airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger
Trigger for RedshiftResumeClusterOperator.
The trigger will asynchronously poll the boto3 API and wait for the Redshift cluster to be in the available state.
- Parameters
- class airflow.providers.amazon.aws.triggers.redshift_cluster.RedshiftDeleteClusterTrigger(cluster_identifier, aws_conn_id='aws_default', waiter_delay=30, waiter_max_attempts=30)[source]¶
Bases:
airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger
Trigger for RedshiftDeleteClusterOperator.
- Parameters
- class airflow.providers.amazon.aws.triggers.redshift_cluster.RedshiftClusterTrigger(aws_conn_id, cluster_identifier, target_status, poke_interval)[source]¶
Bases:
airflow.triggers.base.BaseTrigger
RedshiftClusterTrigger is fired as deferred class with params to run the task in trigger worker.
- Parameters