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,