Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

chore: move compaction progress notification up (to be more frequent) (#7389)

pull/24376/head
Joe-Blount 2023-03-30 12:49:09 -05:00 committed by GitHub
parent 7e6518c7ca
commit 0a51fd55a6
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
compactor2/src/driver.rs
View File

@ -287,16 +287,16 @@ async fn try_compact_partition(
files_next.extend(created_files);
files_next.extend(upgraded_files);
files_next.extend(files_to_keep);
// Report to `timeout_with_progress_checking` that some progress has been made; stop
// if sending this signal fails because something has gone terribly wrong for the other
// end of the channel to not be listening anymore.
if let Err(e) = transmit_progress_signal.send(true) {
return Err(Box::new(e));
}
}
files = files_next;
// Report to `timeout_with_progress_checking` that some progress has been made; stop
// if sending this signal fails because something has gone terribly wrong for the other
// end of the channel to not be listening anymore.
if let Err(e) = transmit_progress_signal.send(true) {
return Err(Box::new(e));
}
}
}