From 675e8012b052b3a092b00d4e062cccdb7119763d Mon Sep 17 00:00:00 2001 From: Dax Raad Date: Wed, 5 Aug 2026 19:22:25 -0400 Subject: [PATCH] chore(core): remove migration test delay --- packages/core/src/database/v1-migration.ts | 19 ++++++++----------- 1 file changed, 8 insertions(+), 11 deletions(-) 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