chore(core-flows): price list skip when no data (#11977)

.changeset/wicked-tomatoes-dream.md

@@ -0,0 +1,5 @@
+---
+"@medusajs/core-flows": patch
+---
+
+chore(core-flows): skip prices list ops when no data

packages/core/core-flows/src/price-list/steps/create-price-list-prices.ts

@@ -59,6 +59,10 @@ export const createPriceListPricesStep = createStep(
       }
     }
 
+    if (!priceListPricesToCreate.length) {
+      return new StepResponse([])
+    }
+
     const createdPrices = await pricingModule.addPriceListPrices(
       priceListPricesToCreate
     )

packages/core/core-flows/src/price-list/steps/create-price-lists.ts

@@ -37,6 +37,10 @@ export const createPriceListsStep = createStep(
       Modules.PRICING
     )
 
+    if (!data.length) {
+      return new StepResponse([])
+    }
+
     const createData = data.map((priceListDTO) => {
       const { prices = [], ...rest } = priceListDTO
       const createPriceListData: CreatePriceListDTO = { ...rest }

packages/core/core-flows/src/price-list/steps/update-price-list-prices.ts

@@ -68,6 +68,10 @@ export const updatePriceListPricesStep = createStep(
       })
     }
 
+    if (!priceListPricesToUpdate.length) {
+      return new StepResponse([])
+    }
+
     const existingPrices = priceIds.length
       ? await pricingModule.listPrices(
           { id: priceIds },

packages/core/core-flows/src/price-list/steps/update-price-lists.ts

@@ -35,6 +35,10 @@ export const updatePriceListsStep = createStep(
       Modules.PRICING
     )
 
+    if (!data.length) {
+      return new StepResponse(void 0)
+    }
+
     const { dataBeforeUpdate, selects, relations } = await getDataBeforeUpdate(
       pricingModule,
       data

packages/core/core-flows/src/price-list/steps/validate-price-lists.ts

@@ -27,6 +27,10 @@ export const validatePriceListsStep = createStep(
       Modules.PRICING
     )
 
+    if (!data.length) {
+      return new StepResponse(void 0)
+    }
+
     const priceListIds = data.map((d) => d.id)
     const priceLists = await pricingModule.listPriceLists({ id: priceListIds })
 

packages/core/core-flows/src/price-list/steps/validate-variant-price-links.ts

@@ -37,14 +37,15 @@ export const validateVariantPriceLinksStepId = "validate-variant-price-links"
  */
 export const validateVariantPriceLinksStep = createStep(
   validateVariantPriceLinksStepId,
-  async (
+  async (data: ValidateVariantPriceLinksStepInput, { container }) => {
-    data: ValidateVariantPriceLinksStepInput,
-    { container }
-  ) => {
     const remoteQuery = container.resolve(
       ContainerRegistrationKeys.REMOTE_QUERY
     )
 
+    if (!data.length) {
+      return new StepResponse(void 0)
+    }
+
     const variantIds: string[] = data
       .map((pl) => pl?.prices?.map((price) => price.variant_id) || [])
       .filter(Boolean)