-
Notifications
You must be signed in to change notification settings - Fork 2k
[BUG]: Collection affinity not working #6115
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
Reviewer ChecklistPlease leverage this checklist to ensure your code review is thorough before approving Testing, Bugs, Errors, Logs, Documentation
System Compatibility
Quality
|
|
This update also ensures the distributed executor reads the renamed Affected Areas• rust/frontend/src/executor/config.rs This summary was automatically generated by @propel-code-bot |
| let retry_config = &config.retry; | ||
| let backoff = retry_config.into(); | ||
| let client_selection_config = config.client_selection_config.clone(); | ||
| let client_selection_config = config.client_selection.clone(); |
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.
[Maintainability] For consistency with the change you made in DistributedExecutorConfig, consider also renaming the field in the DistributedExecutor struct from client_selection_config to client_selection. This would make the naming consistent across both the config and the executor struct itself.
This would involve:
- Changing the field in the
DistributedExecutorstruct definition. - Updating the local variable name and field initialization in
try_from_config. - Updating
self.client_selection_configtoself.client_selectionin thecount,get,knn, andsearchmethods.
Context for Agents
For consistency with the change you made in `DistributedExecutorConfig`, consider also renaming the field in the `DistributedExecutor` struct from `client_selection_config` to `client_selection`. This would make the naming consistent across both the config and the executor struct itself.
This would involve:
1. Changing the field in the `DistributedExecutor` struct definition.
2. Updating the local variable name and field initialization in `try_from_config`.
3. Updating `self.client_selection_config` to `self.client_selection` in the `count`, `get`, `knn`, and `search` methods.
File: rust/frontend/src/executor/distributed.rs
Line: 96## Description of changes _Summarize the changes made by this PR._ - Improvements & Bug fixes - Config name was not what was set in the yaml files. Thereby resorting to defaults which is [1.0, 1.0, 1.0] - Instead of changing the yaml, I changed the name in code to align with all the other fields (they all don't have _config suffix) - New functionality - ... ## Test plan _How are these changes tested?_ - [x] Tests pass locally with `pytest` for python, `yarn test` for js, `cargo test` for rust ## Migration plan None ## Observability plan None ## Documentation Changes None
This PR cherry-picks the commit da85e49 onto release/2026-01-02. If there are unresolved conflicts, please resolve them manually. Co-authored-by: Sanket Kedia <kediasanket11121993@gmail.com>

Description of changes
Summarize the changes made by this PR.
Test plan
How are these changes tested?
pytestfor python,yarn testfor js,cargo testfor rustMigration plan
None
Observability plan
None
Documentation Changes
None