authorgravatar for julius0216@outlook.comJulius Marminge <julius0216@outlook.com> 2026-04-01 08:35:54-07:00
committergravatar for noreply@github.comGitHub <noreply@github.com> 2026-04-01 08:35:54-07:00
log1c3fa673749dd569c904cba45e492e1912e07332
treefe6198d1691decda3bf578b13214eb7da23a954a
parent0ac59d569d6df6568e5750f056a53ad32fd678b1
signature Signed by PGP key B5690EEEBB952194

[codex] migrate Effect.fn in apps/server/src/checkpointing/Layers/CheckpointDiffQuery.ts (#1622)

Co-authored-by: codex <codex@users.noreply.github.com>

1 files changed, 4 insertions(+), 3 deletions(-)

apps/server/src/checkpointing/Layers/CheckpointDiffQuery.ts+4-3
...@@ -21,8 +21,8 @@ const make = Effect.gen(function* () {...@@ -21,8 +21,8 @@ const make = Effect.gen(function* () {
21 const projectionSnapshotQuery = yield* ProjectionSnapshotQuery;21 const projectionSnapshotQuery = yield* ProjectionSnapshotQuery;
22 const checkpointStore = yield* CheckpointStore;22 const checkpointStore = yield* CheckpointStore;
2323
24 const getTurnDiff: CheckpointDiffQueryShape["getTurnDiff"] = (input) =>24 const getTurnDiff: CheckpointDiffQueryShape["getTurnDiff"] = Effect.fn("getTurnDiff")(
25 Effect.gen(function* () {25 function* (input) {
26 const operation = "CheckpointDiffQuery.getTurnDiff";26 const operation = "CheckpointDiffQuery.getTurnDiff";
2727
28 if (input.fromTurnCount === input.toTurnCount) {28 if (input.fromTurnCount === input.toTurnCount) {
...@@ -149,7 +149,8 @@ const make = Effect.gen(function* () {...@@ -149,7 +149,8 @@ const make = Effect.gen(function* () {
149 }149 }
150150
151 return turnDiff;151 return turnDiff;
152 });152 },
153 );
153154
154 const getFullThreadDiff: CheckpointDiffQueryShape["getFullThreadDiff"] = (155 const getFullThreadDiff: CheckpointDiffQueryShape["getFullThreadDiff"] = (
155 input: OrchestrationGetFullThreadDiffInput,156 input: OrchestrationGetFullThreadDiffInput,