diff --git a/src/alerts/mod.rs b/src/alerts/mod.rs index 9523e5e1f..8fce4bcec 100644 --- a/src/alerts/mod.rs +++ b/src/alerts/mod.rs @@ -136,7 +136,7 @@ pub struct Message { impl Message { // checks if message (with a column name) is valid (i.e. the column name is present in the schema) pub fn valid(&self, schema: &Schema, column: &str) -> bool { - return get_field(&schema.fields, column).is_some(); + get_field(&schema.fields, column).is_some() } pub fn extract_column_names(&self) -> Vec<&str> { diff --git a/src/handlers/http/modal/utils/logstream_utils.rs b/src/handlers/http/modal/utils/logstream_utils.rs index e69e78481..1f4615d2f 100644 --- a/src/handlers/http/modal/utils/logstream_utils.rs +++ b/src/handlers/http/modal/utils/logstream_utils.rs @@ -150,7 +150,7 @@ async fn update_stream( return Ok(req.headers().clone()); } validate_and_update_custom_partition(stream_name, custom_partition).await?; - return Ok(req.headers().clone()); + Ok(req.headers().clone()) } async fn validate_and_update_custom_partition( diff --git a/src/handlers/http/otel/opentelemetry.proto.resource.v1.rs b/src/handlers/http/otel/opentelemetry.proto.resource.v1.rs index 51f86481a..328bd19f2 100644 --- a/src/handlers/http/otel/opentelemetry.proto.resource.v1.rs +++ b/src/handlers/http/otel/opentelemetry.proto.resource.v1.rs @@ -31,7 +31,6 @@ pub attributes: Option>, /// dropped_attributes_count is the number of dropped attributes. If the value is 0, then /// no attributes were dropped. - #[serde(rename = "droppedAttributesCount")] pub dropped_attributes_count: Option, } diff --git a/src/utils/arrow/mod.rs b/src/utils/arrow/mod.rs index 87af65735..7fa782faf 100644 --- a/src/utils/arrow/mod.rs +++ b/src/utils/arrow/mod.rs @@ -56,7 +56,6 @@ use serde_json::{Map, Value}; /// } /// ``` /// - /// Replaces columns in a record batch with new arrays. /// /// # Arguments