diff --git a/ingester2/src/buffer_tree/namespace/name_resolver.rs b/ingester2/src/buffer_tree/namespace/name_resolver.rs index d579df558e..04d075544b 100644 --- a/ingester2/src/buffer_tree/namespace/name_resolver.rs +++ b/ingester2/src/buffer_tree/namespace/name_resolver.rs @@ -48,7 +48,12 @@ impl NamespaceNameResolver { .namespaces() .get_by_id(namespace_id) .await? - .expect("resolving namespace name for non-existent namespace id") + .unwrap_or_else(|| { + panic!( + "resolving namespace name for non-existent namespace id {}", + namespace_id + ) + }) .name .into(); diff --git a/ingester2/src/buffer_tree/partition/resolver/sort_key.rs b/ingester2/src/buffer_tree/partition/resolver/sort_key.rs index 9f0d5b9229..1c8b699e6f 100644 --- a/ingester2/src/buffer_tree/partition/resolver/sort_key.rs +++ b/ingester2/src/buffer_tree/partition/resolver/sort_key.rs @@ -40,7 +40,12 @@ impl SortKeyResolver { .partitions() .get_by_id(self.partition_id) .await? - .expect("resolving sort key for non-existent partition") + .unwrap_or_else(|| { + panic!( + "resolving sort key for non-existent partition ID {}", + self.partition_id + ) + }) .sort_key(); Result::<_, iox_catalog::interface::Error>::Ok(s) diff --git a/ingester2/src/buffer_tree/table/name_resolver.rs b/ingester2/src/buffer_tree/table/name_resolver.rs index 24bd7e1c9e..b872c830a2 100644 --- a/ingester2/src/buffer_tree/table/name_resolver.rs +++ b/ingester2/src/buffer_tree/table/name_resolver.rs @@ -48,7 +48,12 @@ impl TableNameResolver { .tables() .get_by_id(table_id) .await? - .expect("resolving table name for non-existent table id") + .unwrap_or_else(|| { + panic!( + "resolving table name for non-existent table id {}", + table_id + ) + }) .name .into();