We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b73a3a9 commit be469a3Copy full SHA for be469a3
server/src/storage/staging.rs
@@ -199,6 +199,12 @@ pub fn convert_disk_files_to_parquet(
199
let staging_files = dir.arrow_files_grouped_exclude_time(time);
200
if staging_files.is_empty() {
201
metrics::STAGING_FILES.with_label_values(&[stream]).set(0);
202
+ metrics::STORAGE_SIZE
203
+ .with_label_values(&["staging", stream, "arrows"])
204
+ .set(0);
205
206
+ .with_label_values(&["staging", stream, "parquet"])
207
208
}
209
210
for (parquet_path, files) in staging_files {
0 commit comments