diff --git a/packages/core/src/database/v1-migration.ts b/packages/core/src/database/v1-migration.ts index b168183c5d..a2e5014eb8 100644 --- a/packages/core/src/database/v1-migration.ts +++ b/packages/core/src/database/v1-migration.ts @@ -487,17 +487,14 @@ export function run(options: Options = {}): Effect.Effect - Effect.gen(function* () { - yield* tx.delete(EventTable).run() - yield* tx.insert(KVTable).values({ key: MIGRATION_STATE_KEY, value: { phase: "sessions" } }).run() - }), - ), - ), - Effect.orDie, - ) + yield* db + .transaction((tx) => + Effect.gen(function* () { + yield* tx.delete(EventTable).run() + yield* tx.insert(KVTable).values({ key: MIGRATION_STATE_KEY, value: { phase: "sessions" } }).run() + }), + ) + .pipe(Effect.orDie) const sourceTotal = yield* countNextSessions(nextPath(options)) const legacyTotal = (yield* db.get<{ value: number }>(sql`SELECT COUNT(*) AS value FROM session`))?.value ?? 0 const cursor = state?.phase === "sessions" ? state.cursor : undefined