Eventual-Inc
Daft
Blog
Docs
Changelog
Blog
Docs
Changelog
Overview
Branches
Benchmarks
Runs
Performance History
Latest Results
fix: pass options in Gravitino PostgreSQL read method
qingfeng-occ:fix_gravitino_postgres_options
27 minutes ago
fix: pass options in Gravitino PostgreSQL read method
qingfeng-occ:fix_gravitino_postgres_options
3 hours ago
Merge branch 'main' into hll/auto
huleilei:hll/auto
4 hours ago
Merge branch 'main' into feat/string-distance-functions
nish2292:feat/string-distance-functions
4 hours ago
fix ut
Abyss-lord:feat-7030
5 hours ago
fix: pass options in Gravitino PostgreSQL read method
qingfeng-occ:fix_gravitino_postgres_options
6 hours ago
fix(functions): support scalar broadcasting in string distance functions - rewrite binary_str_distance to use parse_inputs + create_broadcasted_str_iter, matching the broadcast-aware pattern of other utf8 helpers - fixes out-of-bounds panic for col-scalar (e.g. levenshtein_distance(col("a"), "kitten")) and wrong-length output for scalar-col inputs - handle full-null and empty-input cases explicitly - add TestScalarBroadcast regression tests covering col-scalar, scalar-col, and null-scalar - addresses maintainer review feedback (PR #7068)
nish2292:feat/string-distance-functions
6 hours ago
fix(ray): configure worker startup timeout on runner (#7055) ## Summary The `worker_startup_timeout` execution config never actually worked, because execution config is local to a process. The worker startup code runs on a separate process (flotilla scheduler, not user process) and it calls `get_context().daft_execution_config.worker_startup_timeout`, which gets the local config in the context on that process, not the user defined config, which is passed in together with the plan. In the first place, execution configs are scoped to a single query only, whereas the scheduler and workers can run multiple queries. I think it makes more sense to tie this param with the lifecycle of the scheduler / workers instead of the query, so I opted to move it into `set_runner_ray` instead. ## Details - Move Ray worker startup timeout from execution config to `set_runner_ray(worker_startup_timeout=...)`. - Thread the runner-owned timeout through Flotilla worker startup and support `DAFT_RAY_WORKER_STARTUP_TIMEOUT` for env-created Ray runners. - Remove the nonfunctional execution-config field and update tests around the runner-level API. --------- Co-authored-by: Cursor <cursoragent@cursor.com> Co-authored-by: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
main
7 hours ago
Latest Branches
CodSpeed Performance Gauge
0%
fix: pass options in Gravitino PostgreSQL read method
#7047
3 days ago
cb73d41
qingfeng-occ:fix_gravitino_postgres_options
CodSpeed Performance Gauge
-1%
feat(ray): Implement dynamic scale-in for RaySwordfishActor
#5903
4 hours ago
55953ef
huleilei:hll/auto
CodSpeed Performance Gauge
0%
feat(functions): add string distance/similarity functions
#7068
4 hours ago
ae6fcf2
nish2292:feat/string-distance-functions
© 2026 CodSpeed Technology
Home
Terms
Privacy
Docs