janek
/
mostr
1
0
Fork 1
Code Issues Pull Requests Releases Activity

feat(tasks): report reprocessing issues

This commit is contained in:
xeruf 2024-09-23 13:59:29 +02:00
parent 96ca945263
commit a297f61363
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/tasks.rs
View File

@ -174,16 +174,18 @@ impl TasksRelay {
pub(crate) fn process_overflow(&mut self) { pub(crate) fn process_overflow(&mut self) {
let elements = self.overflow.len(); let elements = self.overflow.len();
let mut issues = 0;
for _ in 0..elements { for _ in 0..elements {
if let Some(event) = self.overflow.pop_front() { if let Some(event) = self.overflow.pop_back() {
if let Some(event) = self.add_prop(event) { if let Some(event) = self.add_prop(event) {
warn!("Unable to sort Event {:?}", event); warn!("Unable to sort Event {:?}", event);
issues += 1;
//self.overflow.push_back(event); //self.overflow.push_back(event);
} }
} }
} }
if elements > 0 { if elements > 0 {
info!("Reprocessed {elements} updates{}", self.sender.url.clone().map(|url| format!(" from {url}")).unwrap_or_default()); info!("Reprocessed {elements} updates with {issues} issues{}", self.sender.url.clone().map(|url| format!(" from {url}")).unwrap_or_default());
} }
} }