diff --git a/src/dags/osdu-ingest-r3.py b/src/dags/osdu-ingest-r3.py index 3d4bd94bf7e7cb00ca8ddb819be3517cffabb227..fa1e6a6ea58f70575d8a2f5f9ad79ed35009f2d7 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