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)
       }
     })