mirror of
https://github.com/meilisearch/meilisearch.git
synced 2025-12-20 19:36:56 +00:00
move output of balance documents to a var
This commit is contained in:
@@ -89,14 +89,15 @@ impl IndexScheduler {
|
|||||||
};
|
};
|
||||||
|
|
||||||
if let Some((remotes, out_name)) = network_topology_change.export_to_process() {
|
if let Some((remotes, out_name)) = network_topology_change.export_to_process() {
|
||||||
network_topology_change.set_moved(self.balance_documents(
|
let moved_documents = self.balance_documents(
|
||||||
remotes,
|
remotes,
|
||||||
out_name,
|
out_name,
|
||||||
network_topology_change.in_name(),
|
network_topology_change.in_name(),
|
||||||
origin,
|
origin,
|
||||||
&progress,
|
&progress,
|
||||||
&self.scheduler.must_stop_processing,
|
&self.scheduler.must_stop_processing,
|
||||||
)?);
|
)?;
|
||||||
|
network_topology_change.set_moved(moved_documents);
|
||||||
}
|
}
|
||||||
network_topology_change.update_state();
|
network_topology_change.update_state();
|
||||||
if network_topology_change.state() == NetworkTopologyState::Finished {
|
if network_topology_change.state() == NetworkTopologyState::Finished {
|
||||||
|
|||||||
Reference in New Issue
Block a user