-
Notifications
You must be signed in to change notification settings - Fork 0
Open
Labels
claudeCreated or actioned by Claude AICreated or actioned by Claude AIupstream-syncIssues for syncing updates with our upstream (cocoindex-io/cocoindex)Issues for syncing updates with our upstream (cocoindex-io/cocoindex)
Description
Upstream Change Summary
Type: new-feature
Difficulty: Medium
Recommendation: Adopt
Upstream added a progress watching API to the App engine, allowing callers to subscribe to progress updates during indexing runs. This introduces UpdateStats tracking per-component in the engine's stats.rs and exposes it via app.rs. This is useful for observability in long-running flows.
Upstream References
- PR: feat: expose a progress watching API for
Appcocoindex-io/cocoindex#1767 - Release: v1.0.0-alpha32
- Upstream repo: https://github.com/cocoindex-io/cocoindex
Relevant Upstream Files / Areas
rust/core/src/engine/app.rs— progress watch subscriptionrust/core/src/engine/stats.rs—UpdateStatsstruct with per-component tracking
Recoco Considerations
- Maps to
crates/recoco-coreengine module (src/engine/equivalent) - The Python binding layer (
rust/py/src/app.rs,rust/py/src/lib.rs) should be excluded entirely UpdateStatsis a pure Rust struct — expose as part of recoco's public API- Consider whether the progress watching API should be part of recoco's public
prelude.rs - The
by_processor→by_componentrename (upstream PR #1768, Python-only) also affectsUpdateStatsin the Python layer — the Rust struct name change is in the stats module and should be adopted for clarity
Integration Notes
The progress API is useful for the library's public surface. Recoco users running persisted flows benefit from observability hooks. This is a straightforward addition but requires deciding on the public API shape for Rust callers.
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
claudeCreated or actioned by Claude AICreated or actioned by Claude AIupstream-syncIssues for syncing updates with our upstream (cocoindex-io/cocoindex)Issues for syncing updates with our upstream (cocoindex-io/cocoindex)