Fix ExecuteOnWorkers
Reviewers: florijan Reviewed By: florijan Differential Revision: https://phabricator.memgraph.io/D1132
This commit is contained in:
parent
5a698444bf
commit
5ad39a8735
@ -56,8 +56,10 @@ class RpcWorkerClients {
|
|||||||
std::vector<std::future<TResult>> futures;
|
std::vector<std::future<TResult>> futures;
|
||||||
for (auto &client : clients_) {
|
for (auto &client : clients_) {
|
||||||
if (client.first == skip_worker_id) continue;
|
if (client.first == skip_worker_id) continue;
|
||||||
|
|
||||||
futures.emplace_back(
|
futures.emplace_back(
|
||||||
std::async(std::launch::async, execute(client.second)));
|
std::async(std::launch::async,
|
||||||
|
[&execute, &client]() { return execute(client.second); }));
|
||||||
}
|
}
|
||||||
return futures;
|
return futures;
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user