You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by jo...@apache.org on 2022/09/20 17:47:16 UTC
[airflow] branch main updated: Move trigger rule outside of documentation (#26525)
This is an automated email from the ASF dual-hosted git repository.
joshfell pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new b7cc73ef0f Move trigger rule outside of documentation (#26525)
b7cc73ef0f is described below
commit b7cc73ef0fb5996b555b77351533990b02d5b70d
Author: Vincent <97...@users.noreply.github.com>
AuthorDate: Tue Sep 20 13:47:08 2022 -0400
Move trigger rule outside of documentation (#26525)
---
tests/system/providers/amazon/aws/example_cloudformation.py | 2 +-
tests/system/providers/amazon/aws/example_emr_serverless.py | 2 +-
tests/system/providers/amazon/aws/example_rds_event.py | 1 +
tests/system/providers/amazon/aws/example_rds_export.py | 4 ++--
tests/system/providers/amazon/aws/example_rds_snapshot.py | 1 +
5 files changed, 6 insertions(+), 4 deletions(-)
diff --git a/tests/system/providers/amazon/aws/example_cloudformation.py b/tests/system/providers/amazon/aws/example_cloudformation.py
index c03236cb55..4df143f2e2 100644
--- a/tests/system/providers/amazon/aws/example_cloudformation.py
+++ b/tests/system/providers/amazon/aws/example_cloudformation.py
@@ -83,10 +83,10 @@ with DAG(
# [START howto_operator_cloudformation_delete_stack]
delete_stack = CloudFormationDeleteStackOperator(
task_id='delete_stack',
- trigger_rule=TriggerRule.ALL_DONE,
stack_name=cloudformation_stack_name,
)
# [END howto_operator_cloudformation_delete_stack]
+ delete_stack.trigger_rule = TriggerRule.ALL_DONE
# [START howto_sensor_cloudformation_delete_stack]
wait_for_stack_delete = CloudFormationDeleteStackSensor(
diff --git a/tests/system/providers/amazon/aws/example_emr_serverless.py b/tests/system/providers/amazon/aws/example_emr_serverless.py
index 42ebccdd7f..d795677e41 100644
--- a/tests/system/providers/amazon/aws/example_emr_serverless.py
+++ b/tests/system/providers/amazon/aws/example_emr_serverless.py
@@ -104,9 +104,9 @@ with DAG(
delete_app = EmrServerlessDeleteApplicationOperator(
task_id='delete_application',
application_id=emr_serverless_app_id,
- trigger_rule=TriggerRule.ALL_DONE,
)
# [END howto_operator_emr_serverless_delete_application]
+ delete_app.trigger_rule = TriggerRule.ALL_DONE
delete_s3_bucket = S3DeleteBucketOperator(
task_id='delete_s3_bucket',
diff --git a/tests/system/providers/amazon/aws/example_rds_event.py b/tests/system/providers/amazon/aws/example_rds_event.py
index b3f5a1867b..bceb4a509a 100644
--- a/tests/system/providers/amazon/aws/example_rds_event.py
+++ b/tests/system/providers/amazon/aws/example_rds_event.py
@@ -95,6 +95,7 @@ with DAG(
subscription_name=rds_subscription_name,
)
# [END howto_operator_rds_delete_event_subscription]
+ delete_subscription.trigger_rule = TriggerRule.ALL_DONE
delete_db_instance = RdsDeleteDbInstanceOperator(
task_id="delete_db_instance",
diff --git a/tests/system/providers/amazon/aws/example_rds_export.py b/tests/system/providers/amazon/aws/example_rds_export.py
index 669de55346..d92759c8ad 100644
--- a/tests/system/providers/amazon/aws/example_rds_export.py
+++ b/tests/system/providers/amazon/aws/example_rds_export.py
@@ -137,16 +137,16 @@ with DAG(
delete_snapshot = RdsDeleteDbSnapshotOperator(
task_id='delete_snapshot',
- trigger_rule=TriggerRule.ALL_DONE,
db_type='instance',
db_snapshot_identifier=rds_snapshot_name,
+ trigger_rule=TriggerRule.ALL_DONE,
)
delete_bucket = S3DeleteBucketOperator(
task_id='delete_bucket',
- trigger_rule=TriggerRule.ALL_DONE,
bucket_name=bucket_name,
force_delete=True,
+ trigger_rule=TriggerRule.ALL_DONE,
)
delete_db_instance = RdsDeleteDbInstanceOperator(
diff --git a/tests/system/providers/amazon/aws/example_rds_snapshot.py b/tests/system/providers/amazon/aws/example_rds_snapshot.py
index 6dca557aa7..303fd0c6d0 100644
--- a/tests/system/providers/amazon/aws/example_rds_snapshot.py
+++ b/tests/system/providers/amazon/aws/example_rds_snapshot.py
@@ -112,6 +112,7 @@ with DAG(
task_id='delete_snapshot_copy',
db_type='instance',
db_snapshot_identifier=rds_snapshot_copy_name,
+ trigger_rule=TriggerRule.ALL_DONE,
)
delete_db_instance = RdsDeleteDbInstanceOperator(