refactor: remove unimplemented!()

This lets us keep the existing test coverage for the new impl.
pull/24376/head
Dom Dwyer 2022-12-01 11:34:25 +01:00
parent 464242ebc6
commit 6639568665
No known key found for this signature in database
GPG Key ID: E4C40DBD9157879A
1 changed files with 5 additions and 1 deletions

View File

@ -215,7 +215,11 @@ impl PartitionData {
// queriers consider writes in the object store as being strictly after
// writes returned from an ingester.
unimplemented!();
assert!(
self.persisting.is_some(),
"must be a persisting batch when marking complete"
);
self.persisting = None;
}
pub(crate) fn partition_id(&self) -> PartitionId {