diff --git a/src/handlers/http/logstream.rs b/src/handlers/http/logstream.rs
index a60bc8237..6478ec9f4 100644
--- a/src/handlers/http/logstream.rs
+++ b/src/handlers/http/logstream.rs
@@ -129,7 +129,7 @@ pub async fn detect_schema(Json(json): Json<Value>) -> Result<impl Responder, St
     Ok((web::Json(schema), StatusCode::OK))
 }
 
-pub async fn schema(stream_name: Path<String>) -> Result<impl Responder, StreamError> {
+pub async fn get_schema(stream_name: Path<String>) -> Result<impl Responder, StreamError> {
     let stream_name = stream_name.into_inner();
 
     // Ensure parseable is aware of stream in distributed mode
diff --git a/src/handlers/http/modal/query_server.rs b/src/handlers/http/modal/query_server.rs
index 25dd11aa2..264f8b9e9 100644
--- a/src/handlers/http/modal/query_server.rs
+++ b/src/handlers/http/modal/query_server.rs
@@ -275,7 +275,7 @@ impl QueryServer {
                         // GET "/logstream/{logstream}/schema" ==> Get schema for given log stream
                         web::resource("/schema").route(
                             web::get()
-                                .to(logstream::schema)
+                                .to(logstream::get_schema)
                                 .authorize_for_stream(Action::GetSchema),
                         ),
                     )
diff --git a/src/handlers/http/modal/server.rs b/src/handlers/http/modal/server.rs
index aef35fcc7..27a4d30f4 100644
--- a/src/handlers/http/modal/server.rs
+++ b/src/handlers/http/modal/server.rs
@@ -349,7 +349,7 @@ impl Server {
                         // GET "/logstream/{logstream}/schema" ==> Get schema for given log stream
                         web::resource("/schema").route(
                             web::get()
-                                .to(logstream::schema)
+                                .to(logstream::get_schema)
                                 .authorize_for_stream(Action::GetSchema),
                         ),
                     )