Eventual-Inc
Daft
Blog
Docs
Changelog
Blog
Docs
Changelog
Overview
Branches
Benchmarks
Runs
Performance History
Latest Results
fix: hide dashboard result preview for unsupported queries (Flotilla) (#6557) ## Summary The results preview tab was added to the dashboard in #6327 but only supports Swordfish queries since Flotilla never calls `on_result_out`. This hides the tab for Flotilla queries (rather than misleadingly displaying a disabled tab which will never become enabled) until we add support for them (follow-up: #6559). Note: for a while running Flotilla queries would actually panic the dashboard server process in `RecordBatch::from_ipc_stream`, but this was coincidentally fixed on main by #6541. This PR addresses the remaining issues: avoiding the empty serialization in the first place, and hiding the broken UI. ## Test plan - [x] `cargo check` passes for `daft-context`, `daft-dashboard` - [x] `tsc --noEmit` passes for dashboard frontend - [x] Manual: run a Flotilla query and verify dashboard doesn't panic, Results tab is hidden - [x] Manual: run a Swordfish query and verify Results tab still works --------- Co-authored-by: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
main
33 minutes ago
fix: reference GitHub issue instead of Linear ticket Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
sam/df-1801-fix-dashboard-ipc-panic-flotilla
56 minutes ago
feat(subscriber): add Event enum and on_event dispatch for subscriber (#6508) ## Changes Made Introduces Event transport enum with OperatorStart/OperatorEnd/Stats variants and a single on_event async method on the Subscriber trait. Ports RuntimeStatsManager to emit all events through on_event, replacing direct per-method calls. Updates dashboard, debug, and python subscribers to implement on_event.
main
1 hour ago
fix
everySympathy:daft-ckpt
1 hour ago
refactor: pull worker refcounting out of BatchManager Worker tracking (increment/decrement/active_workers) is an execution concern, not a buffer management concern. Move it to ExecutionContext where the caller coordinates flush readiness by combining batch_manager.can_flush() (buffer drained) with its own worker count. Also rename remove_input to drain — returns remaining buffered data instead of silently dropping it, preventing accidental data loss.
consolidate-batch-manager-abstraction
1 hour ago
fix: short-circuit evaluation for coalesce (#6525) ## Changes Made <!-- Describe what changes were made and why. Include implementation details if necessary. --> Fixes #4069 by adding proper short-circuit behavior to coalesce. - Added Expr::Coalesce with short-circuit logic - Implemented early-exit in record batch evaluation - Preserved semantics during UDF optimization - Added short-circuit tests ## Related Issues <!-- Link to related GitHub issues, e.g., "Closes #123" --> Closes #4069 --------- Co-authored-by: greptile-apps[bot] <165735046+greptile-apps[bot]@users.noreply.github.com>
main
1 hour ago
chore: regenerate uv.lock with uv 0.11.2, align pre-commit hook The lockfile generated by uv 0.9.2 had a missing transitive dependency (imagehash -> scipy 1.16.1) that caused parse failures in CI which runs uv 0.11.2. Regenerated with `uv lock --upgrade` on 0.11.2 and updated the uv-pre-commit hook from 0.9.22 to 0.11.2 to match. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
everettVT/supply-chain-harden
1 hour ago
refactor: consolidate BatchManager as single buffer abstraction BatchManager now owns per-input buffers, worker tracking, and flush lifecycle — replacing the previous three-abstraction coordination between RowBasedBuffer, InputState, and BatchManager. This enables future data-aware batching strategies (e.g. explode expansion-aware batching) to override `next_batch` on BatchingStrategy and directly inspect/extract from the buffer. Key changes: - BatchManager absorbs InputState (removed) and manages per-input RowBasedBuffer internally - Add `next_batch` to BatchingStrategy trait with default row-count impl - ExecutionContext dispatch loop goes through BatchManager exclusively - Remove the broadcast loop that eagerly updated all buffer bounds - Requirements applied lazily inside BatchManager::next_batch - Add RowBasedBuffer::take_rows/partitions/total_rows for future data-aware strategies - Move BatchManager to its own module (batch_manager.rs), leaving dynamic_batching/ for strategy traits and implementations
consolidate-batch-manager-abstraction
2 hours ago
Latest Branches
CodSpeed Performance Gauge
0%
fix: hide dashboard result preview for unsupported queries (Flotilla)
#6557
21 hours ago
0c7ad66
sam/df-1801-fix-dashboard-ipc-panic-flotilla
CodSpeed Performance Gauge
0%
feat: checkpoint based on distributed key-existence filter
#5931
1 hour ago
4c12bdd
everySympathy:daft-ckpt
CodSpeed Performance Gauge
0%
refactor: consolidate BatchManager as single buffer abstraction
#6566
1 hour ago
a6a3d5e
consolidate-batch-manager-abstraction
© 2026 CodSpeed Technology
Home
Terms
Privacy
Docs