From 1c3fa673749dd569c904cba45e492e1912e07332 Mon Sep 17 00:00:00 2001 From: Julius Marminge Date: Wed, 1 Apr 2026 08:35:54 -0700 Subject: [PATCH] [codex] migrate Effect.fn in apps/server/src/checkpointing/Layers/CheckpointDiffQuery.ts (#1622) Co-authored-by: codex --- .../server/src/checkpointing/Layers/CheckpointDiffQuery.ts | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/apps/server/src/checkpointing/Layers/CheckpointDiffQuery.ts b/apps/server/src/checkpointing/Layers/CheckpointDiffQuery.ts index 5cf26c86da924098f7779997b12600c0849d090e..bbb5a42931514700c3bf1bc7137932e8970be6ed 100644 --- a/apps/server/src/checkpointing/Layers/CheckpointDiffQuery.ts +++ b/apps/server/src/checkpointing/Layers/CheckpointDiffQuery.ts @@ -21,8 +21,8 @@ const make = Effect.gen(function* () { const projectionSnapshotQuery = yield* ProjectionSnapshotQuery; const checkpointStore = yield* CheckpointStore; - const getTurnDiff: CheckpointDiffQueryShape["getTurnDiff"] = (input) => - Effect.gen(function* () { + const getTurnDiff: CheckpointDiffQueryShape["getTurnDiff"] = Effect.fn("getTurnDiff")( + function* (input) { const operation = "CheckpointDiffQuery.getTurnDiff"; if (input.fromTurnCount === input.toTurnCount) { @@ -149,7 +149,8 @@ const make = Effect.gen(function* () { } return turnDiff; - }); + }, + ); const getFullThreadDiff: CheckpointDiffQueryShape["getFullThreadDiff"] = ( input: OrchestrationGetFullThreadDiffInput, -- 2.54.0