From 8af8301df0f9e71d5682ba48fef2aaa667dbc456 Mon Sep 17 00:00:00 2001
From: yan <yan_sushchynski@epam.com>
Date: Mon, 22 Feb 2021 19:11:31 +0300
Subject: [PATCH] Add trigger rule to skip batch tasks
---
src/dags/osdu-ingest-r3.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/src/dags/osdu-ingest-r3.py b/src/dags/osdu-ingest-r3.py
index 3d4bd94..fa1e6a6 100644
--- a/src/dags/osdu-ingest-r3.py
+++ b/src/dags/osdu-ingest-r3.py
@@ -118,7 +118,8 @@ with DAG(
provide_context=True,
dag=dag,
previous_task_id=f"provide_manifest_integrity_task_{batch + 1}",
- batch_number=batch + 1
+ batch_number=batch + 1,
+ trigger_rule="none_failed_or_skipped",
) >> update_status_finished_op
update_status_running_op >> branch_is_batch_op # pylint: disable=pointless-statement
--
GitLab