-
Notifications
You must be signed in to change notification settings - Fork 2.1k
KG vespa error handling + separating relationship transfer & vespa updates #4954
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
The latest updates on your projects. Learn more about Vercel for Git ↗︎
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
PR Summary
Improved knowledge graph clustering by decoupling relationship transfers from Vespa updates, enhancing error handling and observability in backend/onyx/kg/clustering/clustering.py
.
- Split monolithic
_transfer_batch_relationship_and_update_vespa
into separate operations, improving maintainability and failure isolation - Added detailed error handling for Vespa updates with per-document failure logging
- Introduced
_get_batch_kg_processed_documents
for better document batch processing - Added performance metrics and timing logs for each major operation stage
- Improved resilience by ensuring Vespa update failures don't block other document processing
1 file reviewed, 1 comment
Edit PR Review Bot Settings | Greptile
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looks good! And tested locally
3dd7d50
to
1862ca5
Compare
…dates (onyx-dot-app#4954) * feat: move vespa at end in try block * simplify query * mypy * added order by just in case for consistent pagination * liveness probe * kg_p check for both extraction and clustering * fix: better vespa logging
Description
Separated relationship transferring and vespa updates
Proper error handling on vespa updates
How Has This Been Tested?
Locally
Backporting (check the box to trigger backport action)
Note: You have to check that the action passes, otherwise resolve the conflicts manually and tag the patches.