From 352b5b2f16d83e561d38f6d9788188c0c3dfdaf6 Mon Sep 17 00:00:00 2001 From: nardo Date: Thu, 9 Jan 2025 14:37:14 +0800 Subject: [PATCH 1/2] Handles the Failed Imports --- src/Import/Jobs/BulkImportProcessor.php | 15 +++++++++++++++ 1 file changed, 15 insertions(+) diff --git a/src/Import/Jobs/BulkImportProcessor.php b/src/Import/Jobs/BulkImportProcessor.php index 7971efe..7e7f6e7 100644 --- a/src/Import/Jobs/BulkImportProcessor.php +++ b/src/Import/Jobs/BulkImportProcessor.php @@ -49,6 +49,21 @@ public function handle(): void return; } + try { + $this->process(); + } catch (Throwable $e) { + Log::error('[BulkImportProcessor] Error processing import.', [ + 'import_id' => $this->import->id, + 'import_processor' => $this->import->processor, + 'error' => $e->getMessage(), + ]); + + $this->import->update([ + 'status' => Status::FAILED, + 'completed_at' => now(), + ]); + } + Log::info('[BulkImportProcessor] Starting bulk import...', [ 'import_id' => $this->import->id, 'import_processor' => $this->import->processor, From 63b02a4c3c187003b6c97d5f8c5a9b98a8318a3f Mon Sep 17 00:00:00 2001 From: nardo Date: Fri, 17 Jan 2025 13:26:52 +0800 Subject: [PATCH 2/2] Added throw exception --- src/Import/Jobs/BulkImportProcessor.php | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/Import/Jobs/BulkImportProcessor.php b/src/Import/Jobs/BulkImportProcessor.php index 7e7f6e7..1045f8c 100644 --- a/src/Import/Jobs/BulkImportProcessor.php +++ b/src/Import/Jobs/BulkImportProcessor.php @@ -62,6 +62,8 @@ public function handle(): void 'status' => Status::FAILED, 'completed_at' => now(), ]); + + throw $e; } Log::info('[BulkImportProcessor] Starting bulk import...', [