From 4e3090ab263b8c0da97e91d6586275d0f8609db5 Mon Sep 17 00:00:00 2001
From: William Bouchard <46496014+willbouch@users.noreply.github.com>
Date: Tue, 14 Oct 2025 15:24:13 -0400
Subject: [PATCH] chore(core-flows): send error on csv parsing error (#13749)

* chore(core-flows): send error on csv parsing error

* Create two-dragons-visit.md
---
 .changeset/two-dragons-visit.md                          | 5 +++++
 .../src/product/steps/normalize-products-to-chunks.ts    | 9 ++++++++-
 2 files changed, 13 insertions(+), 1 deletion(-)
 create mode 100644 .changeset/two-dragons-visit.md

diff --git a/.changeset/two-dragons-visit.md b/.changeset/two-dragons-visit.md
new file mode 100644
index 0000000000..a87d3f7376
--- /dev/null
+++ b/.changeset/two-dragons-visit.md
@@ -0,0 +1,5 @@
+---
+"@medusajs/core-flows": patch
+---
+
+chore(core-flows): send error on csv parsing error
diff --git a/packages/core/core-flows/src/product/steps/normalize-products-to-chunks.ts b/packages/core/core-flows/src/product/steps/normalize-products-to-chunks.ts
index cde0739707..1eae1e13bf 100644
--- a/packages/core/core-flows/src/product/steps/normalize-products-to-chunks.ts
+++ b/packages/core/core-flows/src/product/steps/normalize-products-to-chunks.ts
@@ -1,11 +1,13 @@
-import { parse, Parser } from "csv-parse"
+import { CsvError, parse, Parser } from "csv-parse"
 import type { HttpTypes, IFileModuleService } from "@medusajs/framework/types"
 import {
   CSVNormalizer,
+  MedusaError,
   Modules,
   productValidators,
 } from "@medusajs/framework/utils"
 import { createStep, StepResponse } from "@medusajs/framework/workflows-sdk"
+import { MedusaErrorTypes } from "@medusajs/utils"
 
 /**
  * The CSV file content to parse.
@@ -238,6 +240,11 @@ export const normalizeCsvToChunksStep = createStep(
           })
         )
       } catch (error) {
+        if (error instanceof CsvError) {
+          return reject(
+            new MedusaError(MedusaErrorTypes.INVALID_DATA, error.message)
+          )
+        }
         reject(error)
       }
     })