Eventual-Inc/Daft - CodSpeed

Daft

Blog Docs Changelog

Performance History

Latest Results

gavin9402:fix_predicate_pushdown

10 hours ago

test: add integration tests for distributed StatSnapshot aggregation Add tests that verify the full interaction between distributed plan node task production, local execution stats emission, and centralized aggregation through the StatisticsManager. Key changes: - Add `LocalSwordfishWorker`: a Worker implementation that executes SwordfishTasks in-process via the local execution pipeline, producing real ExecutionStats with genuine StatSnapshot data. - Add `execute_local_plan()` public API to daft-local-execution for running a LocalPhysicalPlan and getting results + stats. - Fix `get_context()` for non-Python builds to return a default DaftContext instead of panicking. - Add `with_execution_stats()` to MockTaskBuilder for richer mock tasks. - Make `PlanExecutionContext::new()` pub(crate) for test access. Tests cover: - Sort single-partition stats: verifies phase-based filtering where only FINAL_SORT_PHASE Default snapshots contribute row counts - Filter stats with selectivity: verifies FilterSnapshot aggregation with correct rows_in/out and selectivity percentage - Filter multi-partition: verifies correct aggregation across multiple tasks (partitions) All tests use produce_tasks() on real DistributedPipelineNode trees, ensuring the local plans come from actual pipeline node code rather than being hand-constructed. https://claude.ai/code/session_01FSdbkeidSkPZNWT3supLK9

claude/review-distributed-tests-L6JMj

11 hours ago

gavin9402:fix_predicate_pushdown

11 hours ago

feat: support scan_task merge with file_path_column

caican00:to-up-support-scan-task-merge-with-path-column

11 hours ago

Lucas61000:issue-4156

12 hours ago

Lucas61000:issue-4156

13 hours ago

gavin9402:fix_predicate_pushdown

13 hours ago

feat: limit the concurrency of glob dir

caican00:to-up-limit-glob-dir-parallel

14 hours ago

Latest Branches

0%

fix: preserve identity partition predicates when combined with ScalarFn siblings#6695

11 hours ago

289f92b

gavin9402:fix_predicate_pushdown

0%

Add local worker execution and statistics testing infrastructure#6697

13 hours ago

085e7aa

claude/review-distributed-tests-L6JMj

0%

feat: support scan_task merge with `file_path_column`#6696

5 days ago

f953347

caican00:to-up-support-scan-task-merge-with-path-column

© 2026 CodSpeed Technology

Home Terms Privacy Docs