Increase the redshift cluster deletion to 25 minutes in system tests (#62413)

vincbeck · web-flow · commit d65316f4cbdf · 2026-02-24T13:28:51.000-05:00
diff --git a/providers/amazon/tests/system/amazon/aws/example_redshift.py b/providers/amazon/tests/system/amazon/aws/example_redshift.py
@@ -220,6 +220,7 @@
     )
     # [END howto_operator_redshift_delete_cluster]
     delete_cluster.trigger_rule = TriggerRule.ALL_DONE
+    delete_cluster.max_attempts = 50
 
     # [START howto_operator_redshift_delete_cluster_snapshot]
     delete_cluster_snapshot = RedshiftDeleteClusterSnapshotOperator(
diff --git a/providers/amazon/tests/system/amazon/aws/example_redshift_s3_transfers.py b/providers/amazon/tests/system/amazon/aws/example_redshift_s3_transfers.py
@@ -271,6 +271,7 @@ def _insert_data(table_name: str) -> str:
         task_id="delete_cluster",
         cluster_identifier=redshift_cluster_identifier,
         trigger_rule=TriggerRule.ALL_DONE,
+        max_attempts=50,
     )
 
     delete_bucket = S3DeleteBucketOperator(
diff --git a/providers/amazon/tests/system/amazon/aws/example_s3_to_sql.py b/providers/amazon/tests/system/amazon/aws/example_s3_to_sql.py
@@ -249,6 +249,7 @@ def parse_csv_to_generator(filepath):
         task_id="delete_cluster",
         cluster_identifier=redshift_cluster_identifier,
         trigger_rule=TriggerRule.ALL_DONE,
+        max_attempts=50,
     )
 
     chain(
diff --git a/providers/amazon/tests/system/amazon/aws/example_sql_to_s3.py b/providers/amazon/tests/system/amazon/aws/example_sql_to_s3.py
@@ -198,6 +198,7 @@ def create_connection(conn_id_name: str, cluster_id: str):
         task_id="delete_cluster",
         cluster_identifier=redshift_cluster_identifier,
         trigger_rule=TriggerRule.ALL_DONE,
+        max_attempts=50,
     )
 
     chain(

Original file line number	Diff line number	Diff line change
`@@ -220,6 +220,7 @@`
`220`	`220`	`)`
`221`	`221`	`# [END howto_operator_redshift_delete_cluster]`
`222`	`222`	`delete_cluster.trigger_rule = TriggerRule.ALL_DONE`
	`223`	`+ delete_cluster.max_attempts = 50`
`223`	`224`
`224`	`225`	`# [START howto_operator_redshift_delete_cluster_snapshot]`
`225`	`226`	`delete_cluster_snapshot = RedshiftDeleteClusterSnapshotOperator(`
Original file line number	Diff line number	Diff line change
`@@ -271,6 +271,7 @@ def _insert_data(table_name: str) -> str:`
`271`	`271`	`task_id="delete_cluster",`
`272`	`272`	`cluster_identifier=redshift_cluster_identifier,`
`273`	`273`	`trigger_rule=TriggerRule.ALL_DONE,`
	`274`	`+ max_attempts=50,`
`274`	`275`	`)`
`275`	`276`
`276`	`277`	`delete_bucket = S3DeleteBucketOperator(`
Original file line number	Diff line number	Diff line change
`@@ -249,6 +249,7 @@ def parse_csv_to_generator(filepath):`
`249`	`249`	`task_id="delete_cluster",`
`250`	`250`	`cluster_identifier=redshift_cluster_identifier,`
`251`	`251`	`trigger_rule=TriggerRule.ALL_DONE,`
	`252`	`+ max_attempts=50,`
`252`	`253`	`)`
`253`	`254`
`254`	`255`	`chain(`
Original file line number	Diff line number	Diff line change
`@@ -198,6 +198,7 @@ def create_connection(conn_id_name: str, cluster_id: str):`
`198`	`198`	`task_id="delete_cluster",`
`199`	`199`	`cluster_identifier=redshift_cluster_identifier,`
`200`	`200`	`trigger_rule=TriggerRule.ALL_DONE,`
	`201`	`+ max_attempts=50,`
`201`	`202`	`)`
`202`	`203`
`203`	`204`	`chain(`