From 2f4f2b0fe80bb74a641d6ea7a54b7d82f55268e4 Mon Sep 17 00:00:00 2001 From: Meta Vens Date: Fri, 17 Jul 2026 06:44:54 +0100 Subject: [PATCH] Checkpoint each expensive workspace embedding --- epiphany-core/src/workspace_coverage_projector.rs | 13 +++---------- 1 file changed, 3 insertions(+), 10 deletions(-) diff --git a/epiphany-core/src/workspace_coverage_projector.rs b/epiphany-core/src/workspace_coverage_projector.rs index c096b499..6cf5ba63 100644 --- a/epiphany-core/src/workspace_coverage_projector.rs +++ b/epiphany-core/src/workspace_coverage_projector.rs @@ -46,7 +46,7 @@ pub(crate) const ATTEMPT_TYPE: &str = "gamecult.epiphany.workspace_coverage_proj /// Physiological durability cadence, deliberately distinct from Qdrant's /// transport ceiling. On the deployment baseline this bounds checkpoint loss /// to a few minutes while retaining waited, exact batch writes. -const WORKSPACE_COVERAGE_CHECKPOINT_BATCH_POINTS: usize = 8; +const WORKSPACE_COVERAGE_CHECKPOINT_BATCH_POINTS: usize = 1; pub(crate) const CLAIM_KEY: &str = "workspace-coverage-projector-current"; const CLAIM_SCHEMA: &str = "gamecult.epiphany.workspace_coverage_projection_claim.v1"; const ATTEMPT_SCHEMA: &str = "gamecult.epiphany.workspace_coverage_projection_attempt.v1"; @@ -2861,15 +2861,8 @@ mod tests { fn sealed_batch_ranges_preserve_plan_order_and_own_checkpoint_cadence() { let total = WORKSPACE_COVERAGE_CHECKPOINT_BATCH_POINTS * 2 + 3; let ranges = sealed_batch_ranges(total); - assert_eq!( - ranges, - vec![ - 0..WORKSPACE_COVERAGE_CHECKPOINT_BATCH_POINTS, - WORKSPACE_COVERAGE_CHECKPOINT_BATCH_POINTS - ..WORKSPACE_COVERAGE_CHECKPOINT_BATCH_POINTS * 2, - WORKSPACE_COVERAGE_CHECKPOINT_BATCH_POINTS * 2..total, - ] - ); + assert_eq!(WORKSPACE_COVERAGE_CHECKPOINT_BATCH_POINTS, 1); + assert_eq!(ranges.len(), total); assert!( ranges .iter()