Skip to content

Conversation

@trieloff
Copy link
Contributor

@trieloff trieloff commented Dec 10, 2025

Title: Draft: progressive + streaming ingestion; converging estimates; simplified facets (targets main)

This draft PR against main tracks the implementation in #106 (prerelease).

Highlights

  • Worker offload, progressive phases, and streaming ingestion (init/add/phase/end).
  • Consistent estimation while incomplete (f = phase × coverage for streaming), exact at completion.
  • Simplified facet rows ({ value, count, weight } only; estimated until complete).
  • Upgraded demo and docs; tests green.

Please review details, discussion, and validation in #106.

@github-actions
Copy link

This PR will trigger a minor release when merged.

@trieloff trieloff changed the title feat(worker): incremental progressive streaming + converging estimates (draft for main) Draft: progressive + streaming ingestion; converging estimates; simplified facets (targets main) Dec 11, 2025
@trieloff trieloff force-pushed the feat/progressive-incremental-worker branch from 9c825e7 to de9cecb Compare December 11, 2025 13:02
…ngDataChunks); demo; docs; exports

Signed-off-by: Lars Trieloff <[email protected]>
@trieloff trieloff force-pushed the feat/progressive-incremental-worker branch from de9cecb to 372d86f Compare December 11, 2025 13:03
…error handling; keep API compatible

Signed-off-by: Lars Trieloff <[email protected]>
…on + client shim; update demo/tests/docs accordingly

Signed-off-by: Lars Trieloff <[email protected]>
…repo config unchanged; limit lint scope to PR files

Signed-off-by: Lars Trieloff <[email protected]>
…ERVAL_MS from engine.js and replace inline epsilon usage

Signed-off-by: Lars Trieloff <[email protected]>
…js and remove inline 1e-9

Signed-off-by: Lars Trieloff <[email protected]>
…VANCE; remove magic numbers; reuse DataChunks; make auto-advance interval configurable; add onError; bound loadedSlices via maxSlices; add restart mutex/seq

Signed-off-by: Lars Trieloff <[email protected]>
…dd fake-worker browser tests for onError and maxSlices replay bound

Signed-off-by: Lars Trieloff <[email protected]>
…n-import to 2.32.0; regenerate lock for npm ci

Signed-off-by: Lars Trieloff <[email protected]>
… worker to merge shards in-worker; wrapper supports shards with in-worker merging and prefers mergeable quantiles

Signed-off-by: Lars Trieloff <[email protected]>
…s orchestrator and displays shard count in UI

Signed-off-by: Lars Trieloff <[email protected]>
…s it to stream:add/phase/end to avoid 'no streaming run' errors; resolves demo parallel errors

Signed-off-by: Lars Trieloff <[email protected]>
… close previous run on restart to avoid orphaned workers

Signed-off-by: Lars Trieloff <[email protected]>
…to prevent duplicate stream:init and runaway worker spawning; eliminates phantom second run with 0 ingestion

Signed-off-by: Lars Trieloff <[email protected]>
…s pending timers on Done to prevent late finalize from spawning a new run

Signed-off-by: Lars Trieloff <[email protected]>
…to avoid flakiness on earliest frames; CI-friendly

Signed-off-by: Lars Trieloff <[email protected]>
…h COOP/COEP devServer config

Signed-off-by: Lars Trieloff <[email protected]>
…ium can spawn nested workers

Signed-off-by: Lars Trieloff <[email protected]>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants