Eventual-Inc/Daft - CodSpeed

Daft

Blog Docs Changelog

Performance History

Latest Results

chris/fix-it-iceberg-setup

35 minutes ago

feat: enable per-column cache configuration

rchowell/no-compress

1 hour ago

Add debug workflow

chris/fix-it-iceberg-setup

2 hours ago

fix(metrics): forward peak_state_bytes through distributed pipeline nodes Several distributed pipeline nodes (Sort, IntoBatches, Limit, StageCheckpointKeys) define their own RuntimeStats impls that destructure StatSnapshot::Default for phase-aware row/byte accounting. None of them forwarded the new peak_state_bytes field, so peak memory reported by stateful local sinks (Sort, Aggregate, TopN, Dedup) was silently dropped at the distributed boundary. On Flotilla this surfaced as a "-" in the dashboard's Peak Memory column even for the distributed Sort node whose final-sort phase wraps the local Sort sink. Adds a forward_default_snapshot_peak helper on BaseCounters that the four affected handlers call after their own bookkeeping. Distributed nodes that use the catch-all DefaultRuntimeStats (Aggregate, TopN, Distinct, etc.) were already covered by the previous commit. Extends the existing distributed Sort regression test to assert peak_state_bytes propagates to the exported snapshot. https://claude.ai/code/session_012tEp7R8QPzkK16NmBbD62d

claude/review-memory-instrumentation-mV5Sb

2 hours ago

refactor(distributed): replace started/ended bools with LifecyclePhase enum Per review: collapse the `started`/`ended` flags on `OperatorLifecycle` into a 3-state enum (`Pending` | `Started` | `Ended`) so illegal states like `ended && !started` are unrepresentable. `produce_complete` stays as a sticky bool: `OnEndStream::Drop` can fire before the scheduler emits the first `TaskEvent::Submitted`, so the "stream done" signal can arrive while we're still in `Pending`. Folding it into the phase enum loses the signal in that race. `pending_tasks` keeps its u64 type (it's a count, not a phase). End fires via `maybe_end` when `phase == Started && produce_complete && pending_tasks == 0`. `force_end` transitions `Started → Ended` unconditionally for the abort path. All 6 lifecycle tests pass. https://claude.ai/code/session_014ocRSVFrAoHhiiKMKX7xgT

claude/fix-operator-events-SIs6N

3 hours ago

style: rustfmt fixups for peak-state-bytes tests https://claude.ai/code/session_012tEp7R8QPzkK16NmBbD62d

claude/review-memory-instrumentation-mV5Sb

3 hours ago

chris/fix-it-iceberg-setup

3 hours ago

feat: refactored out fns in finalize_probe

euan/optimize-asof

3 hours ago

Latest Branches

+10%

fix(test): handle transient iceberg rest catalog startup failures#6880

1 hour ago

9f703f1

chris/fix-it-iceberg-setup

+11%

perf: enable per-column compression configuration#6884

2 hours ago

3500d09

rchowell/no-compress

0%

feat(metrics): track peak resident state bytes for stateful operators#6883

3 hours ago

e0f588b

claude/review-memory-instrumentation-mV5Sb

© 2026 CodSpeed Technology

Home Terms Privacy Docs