diff --git a/crates/abq_queue/src/persistence/manifest.rs b/crates/abq_queue/src/persistence/manifest.rs index 40fa8c4e..11830dab 100644 --- a/crates/abq_queue/src/persistence/manifest.rs +++ b/crates/abq_queue/src/persistence/manifest.rs @@ -38,6 +38,10 @@ impl ManifestView { self.items.len() } + pub fn is_empty(&self) -> bool { + self.items.is_empty() + } + fn get_partition_for_entity(self, entity_tag: Tag) -> Vec { let Self { mut items, diff --git a/crates/abq_queue/tests/integration.rs b/crates/abq_queue/tests/integration.rs index e2d801ab..5273ee0b 100644 --- a/crates/abq_queue/tests/integration.rs +++ b/crates/abq_queue/tests/integration.rs @@ -275,7 +275,7 @@ fn sort_results_owned(results: &mut [FlatResult<'_>]) -> Vec<(u32, String)> { .collect() } -fn flatten_queue_results<'a>( +fn flatten_queue_results( results: impl std::borrow::Borrow, ) -> (Vec<(u32, String)>, Summary) { let results = results.borrow();