diff --git a/dlt/load/load.py b/dlt/load/load.py
index 07259c05d9..7e9cedeaa8 100644
--- 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)