server: always remove unprocessed label when processing rules
This commit is contained in:
parent
fa99959508
commit
08abf31fa9
@ -1037,11 +1037,6 @@ 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());
|
|
||||||
//nm.tag_remove("inbox", &id)?;
|
//nm.tag_remove("inbox", &id)?;
|
||||||
let t = "inbox".to_string();
|
let t = "inbox".to_string();
|
||||||
rm_mutations
|
rm_mutations
|
||||||
@ -1049,6 +1044,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());
|
||||||
}
|
}
|
||||||
info!("Adding {} distinct labels", add_mutations.len());
|
info!("Adding {} distinct labels", add_mutations.len());
|
||||||
for (tag, ids) in add_mutations.iter() {
|
for (tag, ids) in add_mutations.iter() {
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user