From 3488ca3570060449d3855eeba79a40e1f9938f9c Mon Sep 17 00:00:00 2001 From: Julius Marminge Date: Wed, 1 Apr 2026 08:44:49 -0700 Subject: [PATCH] [codex] migrate Effect.fn in apps/server/src/persistence/Migrations.ts (#1632) Co-authored-by: codex --- apps/server/src/persistence/Migrations.ts | 27 ++++++++++++----------- 1 file changed, 14 insertions(+), 13 deletions(-) diff --git a/apps/server/src/persistence/Migrations.ts b/apps/server/src/persistence/Migrations.ts index c759665f0648a6c9548118dd11a906f6e6c10b26..47102471acf045e6f8b91196feca9c706e5168c0 100644 --- a/apps/server/src/persistence/Migrations.ts +++ b/apps/server/src/persistence/Migrations.ts @@ -92,19 +92,20 @@ export interface RunMigrationsOptions { * * @returns Effect containing array of executed migrations */ -export const runMigrations = ({ toMigrationInclusive }: RunMigrationsOptions = {}) => - Effect.gen(function* () { - yield* Effect.log( - toMigrationInclusive === undefined - ? "Running all migrations..." - : `Running migrations 1 through ${toMigrationInclusive}...`, - ); - const executedMigrations = yield* run({ loader: makeMigrationLoader(toMigrationInclusive) }); - yield* Effect.log("Migrations ran successfully").pipe( - Effect.annotateLogs({ migrations: executedMigrations.map(([id, name]) => `${id}_${name}`) }), - ); - return executedMigrations; - }); +export const runMigrations = Effect.fn("runMigrations")(function* ({ + toMigrationInclusive, +}: RunMigrationsOptions = {}) { + yield* Effect.log( + toMigrationInclusive === undefined + ? "Running all migrations..." + : `Running migrations 1 through ${toMigrationInclusive}...`, + ); + const executedMigrations = yield* run({ loader: makeMigrationLoader(toMigrationInclusive) }); + yield* Effect.log("Migrations ran successfully").pipe( + Effect.annotateLogs({ migrations: executedMigrations.map(([id, name]) => `${id}_${name}`) }), + ); + return executedMigrations; +}); /** * Layer that runs migrations when the layer is built. -- 2.54.0