Fix mistake in configurator

This commit is contained in:
Sasha Krassovsky
2023-11-16 21:00:27 +01:00
parent a5d0f1a92e
commit a1db731f4a

View File

@@ -36,10 +36,12 @@ fn configurator_main_loop(compute: &Arc<ComputeNode>) {
info!("got merge request");
state.status = ComputeStatus::Merging;
compute.state_changed.notify_all();
let connstr = state.merge_src_connstr.clone().unwrap();
drop(state);
let mut new_status = ComputeStatus::Failed;
if let Err(e) = compute.merge(&state.merge_src_connstr.clone().unwrap())
if let Err(e) = compute.merge(&connstr)
{
drop(state);
info!("could not merge compute node: {}", e);
}
else