diff --git a/src/runner.ts b/src/runner.ts index 7252897e..3146faf7 100644 --- a/src/runner.ts +++ b/src/runner.ts @@ -179,6 +179,11 @@ export default async (options: RunnerOption): Promise => { const db = Db((options as RunnerOptionClient).dbClient || (options as RunnerOptionUrl).databaseUrl, logger) try { await db.createConnection() + + if (!options.noLock) { + await lock(db) + } + if (options.schema) { const schemas = getSchemas(options.schema) if (options.createSchema) { @@ -192,10 +197,6 @@ export default async (options: RunnerOption): Promise => { await ensureMigrationsTable(db, options) - if (!options.noLock) { - await lock(db) - } - const [migrations, runNames] = await Promise.all([ loadMigrations(db, options, logger), getRunMigrations(db, options),