remove a bunch of confusing logs

This commit is contained in:
Tamo 2023-03-21 17:58:36 +01:00
parent 5ecfa3570f
commit 8ebc2b19ea

View File

@ -544,20 +544,9 @@ impl IndexScheduler {
fn run(&self) { fn run(&self) {
let run = self.private_clone(); let run = self.private_clone();
if run.cluster.is_some() {
log::warn!("Run in a cluster");
} else {
log::warn!("Run not in a cluster");
}
// if we're a follower we starts a thread to register the tasks coming from the leader // if we're a follower we starts a thread to register the tasks coming from the leader
if let Some(Cluster::Follower(ref follower)) = self.cluster { if let Some(Cluster::Follower(ref follower)) = self.cluster {
let this = self.private_clone(); let this = self.private_clone();
if this.cluster.is_some() {
log::warn!("this in a cluster");
} else {
log::warn!("this not in a cluster");
}
let follower = follower.clone(); let follower = follower.clone();
std::thread::spawn(move || loop { std::thread::spawn(move || loop {
let (task, content) = follower.get_new_task(); let (task, content) = follower.get_new_task();