diff --git a/.changeset/nine-ways-teach.md b/.changeset/nine-ways-teach.md new file mode 100644 index 0000000000..f647229fb4 --- /dev/null +++ b/.changeset/nine-ways-teach.md @@ -0,0 +1,5 @@ +--- +"@medusajs/utils": patch +--- + +chore(): Throw on migration up/down fail diff --git a/packages/core/utils/src/modules-sdk/migration-scripts/migration-down.ts b/packages/core/utils/src/modules-sdk/migration-scripts/migration-down.ts index d520d792d7..35cb9c39d5 100644 --- a/packages/core/utils/src/modules-sdk/migration-scripts/migration-down.ts +++ b/packages/core/utils/src/modules-sdk/migration-scripts/migration-down.ts @@ -2,6 +2,7 @@ import { LoaderOptions, Logger, ModulesSdkTypes } from "@medusajs/types" import { mikroOrmCreateConnection } from "../../dal" import { loadDatabaseConfig } from "../load-module-database-config" import { Migrations } from "../../migrations" +import { MedusaError } from "../../common/errors" const TERMINAL_SIZE = process.stdout.columns @@ -55,6 +56,11 @@ export function buildRevertMigrationScript({ moduleName, pathToMigrations }) { } } catch (error) { logger.error(`Failed with error ${error.message}`, error) + throw new MedusaError( + MedusaError.Types.DB_ERROR, + error.message, + error.code + ) } } } diff --git a/packages/core/utils/src/modules-sdk/migration-scripts/migration-up.ts b/packages/core/utils/src/modules-sdk/migration-scripts/migration-up.ts index 53485e781e..e09af4c917 100644 --- a/packages/core/utils/src/modules-sdk/migration-scripts/migration-up.ts +++ b/packages/core/utils/src/modules-sdk/migration-scripts/migration-up.ts @@ -2,6 +2,7 @@ import { LoaderOptions, Logger, ModulesSdkTypes } from "@medusajs/types" import { mikroOrmCreateConnection } from "../../dal" import { loadDatabaseConfig } from "../load-module-database-config" import { Migrations } from "../../migrations" +import { MedusaError } from "../../common/errors" const TERMINAL_SIZE = process.stdout.columns @@ -52,6 +53,7 @@ export function buildMigrationScript({ moduleName, pathToMigrations }) { } } catch (error) { logger.error(`Failed with error ${error.message}`, error) + throw new MedusaError(MedusaError.Types.DB_ERROR, error.message) } } }