Eventual-Inc/Daft - CodSpeed

Daft

Blog Docs Changelog

Performance History

Latest Results

run prints and refactor blocking sink

colin/plan-caching

6 hours ago

colin/plan-caching

7 hours ago

print plan reuse

colin/plan-caching

8 hours ago

isolate runtime stats

colin/pipeline-message

12 hours ago

Merge branch 'main' into slade/reuse-flight-connection

slade/reuse-flight-connection

12 hours ago

refactor(ai): move embed_text expression building into Provider Restructure the embed_text API to follow a three-method provider pattern: 1. get_text_embedder_descriptor() - validates options, returns a serializable TypedDict descriptor (no logic, just data) 2. get_text_embedder(descriptor) - instantiates the protocol implementation 3. embed_text() - builds the Daft Expression (default sync UDF path) Key changes: - TextEmbedderDescriptor is now a TypedDict instead of an ABC - Descriptor validation/dimension resolution moves into providers - Expression building moves from DSL function into Provider.embed_text() - DSL embed_text() becomes a one-liner delegating to the provider - Providers can override embed_text() for custom behavior (async, Rust ops) - _TextEmbedderExpression takes TextEmbedder directly, not a descriptor This enables: - Serializable descriptors for plan introspection (no pickling required) - Provider-controlled expression instantiation (custom or default) - Future Rust operator implementations via embed_text() override - Clean separation: descriptor = data, provider = factory Closes #6425 Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

refactor/ai-provider-expressions

12 hours ago

insert fingerprint

colin/plan-caching

12 hours ago

refactor(observability): move bytes_retained tracking from generic nodes to individual sinks Each operator now reports its own retained bytes at the point where data is actually stored, rather than the generic node dispatch loop tracking input size (which overstates for operators that transform during accumulation). - Verbatim accumulators (Sort, Pivot, IntoPartitions, Repartition, WindowOrderByOnly): track input.size_bytes() - Transform-then-accumulate (Aggregate, TopN): track post-transform size - Reset handled centrally in BlockingSinkNode before finalize Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

desmond/per-operator-bytes-retained

13 hours ago

Latest Branches

0%

feat(swordfish): plan caching with ActivePlansRegistry#6278

6 hours ago

71f661a

colin/plan-caching

0%

feat(swordfish): introduce PipelineMessage with input_id tracking#6277

12 hours ago

ac669fc

colin/pipeline-message

0%

chore: Provider Flight Server in Rust#6519

13 hours ago

a95f0fd

slade/reuse-flight-connection

© 2026 CodSpeed Technology

Home Terms Privacy Docs