diff --git a/server/src/metadata.rs b/server/src/metadata.rs index 5d8fe8223..16c2e59d7 100644 --- a/server/src/metadata.rs +++ b/server/src/metadata.rs @@ -148,16 +148,18 @@ impl STREAM_INFO { let alerts = storage .get_alerts(&stream.name) .await - .map_err(|_| Error::AlertNotInStore(stream.name.to_owned()))?; + .map_err(|_| Error::AlertNotInStore(stream.name.to_owned())); + let schema = storage .get_schema(&stream.name) .await .map_err(|e| e.into()) .and_then(parse_string) .map_err(|_| Error::SchemaNotInStore(stream.name.to_owned()))?; + let metadata = LogStreamMetadata { schema, - alerts, + alerts: alerts.unwrap_or_default(), ..Default::default() };