diff --git a/gcp_airflow_foundations/common/gcp/load_builder.py b/gcp_airflow_foundations/common/gcp/load_builder.py index 35ef39a9..760b3c0e 100644 --- a/gcp_airflow_foundations/common/gcp/load_builder.py +++ b/gcp_airflow_foundations/common/gcp/load_builder.py @@ -126,7 +126,7 @@ def load_builder( else: preceding_task >> parse_schema >> ods_task_group >> delete_staging_table - done = DummyOperator(task_id="done", trigger_rule=TriggerRule.ALL_DONE) + done = DummyOperator(task_id="done", trigger_rule=TriggerRule.ALL_SUCCESS) if dlp_table_config.get_is_on():