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

Merge branch 'main' into pjb-update-readme

pull/24376/head
Phil Bracikowski 2023-03-30 13:16:43 -07:00 committed by GitHub
parent 4adb4975e1 0a51fd55a6
commit 144a0948a2
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));
}
}
}