server: remove unprocessed appropriately
This commit is contained in:
@@ -1028,11 +1028,6 @@ pub async fn label_unprocessed(
|
|||||||
.push(id.clone());
|
.push(id.clone());
|
||||||
}
|
}
|
||||||
//nm.tag_remove("unprocessed", &id)?;
|
//nm.tag_remove("unprocessed", &id)?;
|
||||||
let t = "unprocessed".to_string();
|
|
||||||
rm_mutations
|
|
||||||
.entry(t)
|
|
||||||
.or_insert_with(|| Vec::new())
|
|
||||||
.push(id.clone());
|
|
||||||
} else {
|
} else {
|
||||||
if add_tags.is_empty() {
|
if add_tags.is_empty() {
|
||||||
let t = "Grey".to_string();
|
let t = "Grey".to_string();
|
||||||
@@ -1041,6 +1036,11 @@ pub async fn label_unprocessed(
|
|||||||
.or_insert_with(|| Vec::new())
|
.or_insert_with(|| Vec::new())
|
||||||
.push(id.clone());
|
.push(id.clone());
|
||||||
}
|
}
|
||||||
|
let t = "unprocessed".to_string();
|
||||||
|
rm_mutations
|
||||||
|
.entry(t)
|
||||||
|
.or_insert_with(|| Vec::new())
|
||||||
|
.push(id.clone());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
println!("Adding {} distinct labels", add_mutations.len());
|
println!("Adding {} distinct labels", add_mutations.len());
|
||||||
|
|||||||
Reference in New Issue
Block a user