diff --git a/server/src/handlers/http/logstream.rs b/server/src/handlers/http/logstream.rs index 8b62d8f18..f3c9c93d3 100644 --- a/server/src/handlers/http/logstream.rs +++ b/server/src/handlers/http/logstream.rs @@ -39,8 +39,8 @@ pub async fn delete(req: HttpRequest) -> Result { let objectstore = CONFIG.storage().get_object_store(); - if !objectstore.stream_exists(&stream_name).await? { - return Err(StreamError::StreamNotFound(stream_name.to_string())); + if !metadata::STREAM_INFO.stream_exists(&stream_name) { + return Err(StreamError::StreamNotFound(stream_name)); } objectstore.delete_stream(&stream_name).await?;