diff --git a/src/Import/Jobs/BulkImportProcessor.php b/src/Import/Jobs/BulkImportProcessor.php index 7971efe..1045f8c 100644 --- a/src/Import/Jobs/BulkImportProcessor.php +++ b/src/Import/Jobs/BulkImportProcessor.php @@ -49,6 +49,23 @@ 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(), + ]); + + throw $e; + } + Log::info('[BulkImportProcessor] Starting bulk import...', [ 'import_id' => $this->import->id, 'import_processor' => $this->import->processor,