-
Notifications
You must be signed in to change notification settings - Fork 1.4k
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
[BUG] Make memberlist use ips for routing #3405
base: main
Are you sure you want to change the base?
Conversation
Reviewer ChecklistPlease leverage this checklist to ensure your code review is thorough before approving Testing, Bugs, Errors, Logs, Documentation
System Compatibility
Quality
|
✅ The Helm chart's version was changed. Your changes to the chart will be published upon merge to |
for member in self._curr_memberlist: | ||
if member.id == assignment: | ||
if member.ip is not None and member.ip != "": | ||
print(f"[HAMMAD DEBUG] Using member ip: {member.ip}") |
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.
todo: remove
@@ -77,6 +78,8 @@ def prepare_segments_for_new_collection( | |||
|
|||
@override | |||
def delete_segments(self, collection_id: UUID) -> Sequence[UUID]: | |||
# TODO: this should be a pass, delete_collection is expected to delete segments in |
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.
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.
thanks, i will remove the get_segments() calls.
Description of changes
Summarize the changes made by this PR.
Test plan
How are these changes tested?
Added a test which adds data to a collection, kills the query service pods and waits for them to be ready, simulating a roll out of sorts. Then it issues another query and make sure the query succeeds with updated routing. Before this change, this test failed.
pytest
for python,yarn test
for js,cargo test
for rustDocumentation Changes
None