From 0a9b5c3acd069c0d96584cde3da1780d96ed5432 Mon Sep 17 00:00:00 2001 From: Dave Date: Tue, 2 Jul 2024 12:31:27 +0200 Subject: [PATCH] do not complete package if failed jobs are present --- dlt/load/load.py | 1 + 1 file changed, 1 insertion(+) 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)