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

chore: address a couple post-merge PR comments

feat/add-retention-period-to-catalog_core
wayne warren 2025-06-02 19:23:58 -06:00
parent acdb8f650e
commit c5fdaa7661
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
influxdb3_catalog/src/catalog/update.rs
View File

@ -709,7 +709,11 @@ impl Catalog {
db_name: &str, db_name: &str,
duration: Duration, duration: Duration,
) -> Result<OrderedCatalogBatch> { ) -> Result<OrderedCatalogBatch> {
info!("create new retention policy"); info!(
db_name,
duration_ns = duration.as_nanos(),
"create new retention policy"
);
let Some(db) = self.db_schema(db_name) else { let Some(db) = self.db_schema(db_name) else {
return Err(CatalogError::NotFound); return Err(CatalogError::NotFound);
}; };
@ -734,7 +738,7 @@ impl Catalog {
&self, &self,
db_name: &str, db_name: &str,
) -> Result<OrderedCatalogBatch> { ) -> Result<OrderedCatalogBatch> {
info!("delete retention policy"); info!(db_name, "delete retention policy");
let Some(db) = self.db_schema(db_name) else { let Some(db) = self.db_schema(db_name) else {
return Err(CatalogError::NotFound); return Err(CatalogError::NotFound);
}; };