-
-
Notifications
You must be signed in to change notification settings - Fork 90
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
Fix index worker depletion #1225
Conversation
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.
e03c9a5
to
87bb4fa
Compare
@dominiklohmann I added a second change that I thought makes sense. Please have another look. |
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.
I really like this additional change, just two nits. I did not verify this to work locally.
libvast/src/system/index.cpp
Outdated
await_evaluation_maps( | ||
self, iter->second.expression, actors, | ||
[=](caf::expected<pending_query_map> maybe_pqm) { | ||
auto& st = self->state; | ||
auto drop = [&] { | ||
self->state.idle_workers.emplace_back(std::move(*worker)); |
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.
I think we should capture worker = std::move(*worker)
in the lambda that we pass to await_evaluation_maps
. This code does not need to know about the optional
wrapping.
87bb4fa
to
eb5a16d
Compare
📔 Description
A bug that causes the removal of index workers in case of false positive candidate partitions is fixed here.
📝 Checklist