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

refactor: address review comment

pull/24376/head
Nga Tran 2021-12-01 12:25:42 -05:00
parent 878c59c0d2
commit 254d35a6c2
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
server/src/db.rs
View File

@ -577,8 +577,8 @@ impl Db {
// Capture ID of to be created chunk for the in-progress compacting OS chunks
let (to_be_created_chunk_id, compacting_os) =
match chunk.in_lifecycle_compacting_object_store() {
Some(id) => (id, true),
_ => (chunk.addr().chunk_id, false),
Some(id) => (Some(id), true),
_ => (None, false),
};
if matches!(chunk.stage(), ChunkStage::Persisted { .. })
@ -595,7 +595,7 @@ impl Db {
affected_persisted_chunks.push(ChunkAddrWithoutDatabase {
table_name: Arc::clone(&chunk.addr().table_name),
partition_key: Arc::clone(&chunk.addr().partition_key),
chunk_id: to_be_created_chunk_id,
chunk_id: to_be_created_chunk_id.unwrap(),
});
}
}