do not complete package if failed jobs are present

dlt-hub · Jul 2, 2024 · 0a9b5c3 · 0a9b5c3
1 parent c516fbc
commit 0a9b5c3
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/dlt/load/load.py b/dlt/load/load.py
@@ -500,6 +500,7 @@ def load_single_package(self, load_id: str, schema: Schema) -> None:
         if (
             len(self.load_storage.list_new_jobs(load_id)) == 0
             and len(self.load_storage.normalized_packages.list_started_jobs(load_id)) == 0
+            and len(self.load_storage.normalized_packages.list_failed_jobs(load_id)) == 0
         ):
             self.complete_package(load_id, schema, False)