From c0366679daef314e7876d26c834cb85016fde6eb Mon Sep 17 00:00:00 2001 From: Julius Marminge Date: Wed, 1 Apr 2026 00:26:35 -0700 Subject: [PATCH] migrate Effect.fn in apps/server/src/checkpointing/Layers/CheckpointDiffQuery.ts 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 5cf26c86da..bbb5a42931 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,