From 0fb61f424a9d226414a69e516e839aadf241108e Mon Sep 17 00:00:00 2001 From: Jackson Newhouse Date: Fri, 20 Dec 2024 15:08:52 -0800 Subject: [PATCH] fix: PR feedback --- influxdb3_write/src/persister.rs | 4 ++-- influxdb3_write/src/write_buffer/mod.rs | 3 --- 2 files changed, 2 insertions(+), 5 deletions(-) diff --git a/influxdb3_write/src/persister.rs b/influxdb3_write/src/persister.rs index 041e573008e..d321587dd68 100644 --- a/influxdb3_write/src/persister.rs +++ b/influxdb3_write/src/persister.rs @@ -755,8 +755,8 @@ mod tests { }; persister.persist_snapshot(&info_file).await.unwrap(); } - let snapshots = persister.load_snapshots(9500).await.unwrap(); - // We asked for the most recent 9500 so there should be 9001 of them + let snapshots = persister.load_snapshots(1500).await.unwrap(); + // We asked for the most recent 1500 so there should be 1001 of them assert_eq!(snapshots.len(), 1001); assert_eq!(snapshots[0].next_file_id.as_u64(), 1000); assert_eq!(snapshots[0].wal_file_sequence_number.as_u64(), 1000); diff --git a/influxdb3_write/src/write_buffer/mod.rs b/influxdb3_write/src/write_buffer/mod.rs index 0a59aa53d9e..7a8535d0997 100644 --- a/influxdb3_write/src/write_buffer/mod.rs +++ b/influxdb3_write/src/write_buffer/mod.rs @@ -1766,9 +1766,6 @@ mod tests { assert_eq!(ParquetFileId::next_id().as_u64(), 6); } - #[tokio::test] - async fn catalog_ops_correctly_ordered() {} - /// This is the reproducer for [#25277][see] /// /// [see]: https://github.com/influxdata/influxdb/issues/25277