diff --git a/litellm-rust/crates/traces-cache/tests/read.rs b/litellm-rust/crates/traces-cache/tests/read.rs index 2c7098b3d37..d714d7c9ed4 100644 --- a/litellm-rust/crates/traces-cache/tests/read.rs +++ b/litellm-rust/crates/traces-cache/tests/read.rs @@ -571,7 +571,13 @@ async fn failed_batch_spend_lookup_falls_back_to_each_run_instead_of_losing_ever let by_ref: HashMap<&str, f64> = page .data .iter() - .map(|run| (run.trace_ref.as_str(), run.spend.expect("run's own spend read should have succeeded"))) + .map(|run| { + ( + run.trace_ref.as_str(), + run.spend + .expect("run's own spend read should have succeeded"), + ) + }) .collect(); assert_eq!(by_ref["ref-a"], 1.5); assert_eq!(by_ref["ref-b"], 2.5); diff --git a/litellm-rust/crates/traces-clickhouse/src/insert.rs b/litellm-rust/crates/traces-clickhouse/src/insert.rs index 9e6452844f4..d45cc8d53b8 100644 --- a/litellm-rust/crates/traces-clickhouse/src/insert.rs +++ b/litellm-rust/crates/traces-clickhouse/src/insert.rs @@ -239,8 +239,7 @@ mod tests { use rstest::rstest; use serde_json::json; - use super::Error; - use super::{shared_rows, write_rows}; + use super::{Error, shared_rows, write_rows}; #[rstest] fn encoded_limit_counts_utf8_bytes_across_rows() { diff --git a/litellm-rust/crates/traces-clickhouse/src/reads.rs b/litellm-rust/crates/traces-clickhouse/src/reads.rs index 7a5005b8cb0..eaaeb4fef82 100644 --- a/litellm-rust/crates/traces-clickhouse/src/reads.rs +++ b/litellm-rust/crates/traces-clickhouse/src/reads.rs @@ -1,6 +1,5 @@ use litellm_http::Client; -use litellm_storage_clickhouse::Error as StorageError; -use litellm_storage_clickhouse::{Query, fetch}; +use litellm_storage_clickhouse::{Error as StorageError, Query, fetch}; use litellm_traces::query::named as contracts; use litellm_traces_cache::{StoreError, TraceStore}; diff --git a/litellm-rust/crates/traces-clickhouse/src/schema.rs b/litellm-rust/crates/traces-clickhouse/src/schema.rs index 07590b59338..6a39bd24041 100644 --- a/litellm-rust/crates/traces-clickhouse/src/schema.rs +++ b/litellm-rust/crates/traces-clickhouse/src/schema.rs @@ -3,8 +3,7 @@ use litellm_migrate::Migration; use serde::Serialize; use std::time::Duration; -use super::Connection; -use super::Error; +use super::{Connection, Error}; const SCHEMA_REQUEST_TIMEOUT: Duration = Duration::from_secs(30); diff --git a/litellm-rust/crates/traces-clickhouse/src/sql.rs b/litellm-rust/crates/traces-clickhouse/src/sql.rs index 80b3ec88534..dfa0618773a 100644 --- a/litellm-rust/crates/traces-clickhouse/src/sql.rs +++ b/litellm-rust/crates/traces-clickhouse/src/sql.rs @@ -3,8 +3,10 @@ use std::collections::BTreeMap; use litellm_http::Client; use litellm_traces::ReadQuery; -use super::query::{lens::*, named::*}; -use super::{Connection, Error, Parameter}; +use super::{ + Connection, Error, Parameter, + query::{lens::*, named::*}, +}; use litellm_storage_clickhouse::{Query, fetch_json}; pub async fn execute_named_read( diff --git a/litellm-rust/crates/traces-clickhouse/tests/migrations.rs b/litellm-rust/crates/traces-clickhouse/tests/migrations.rs index cd23484566f..09fd3e78da8 100644 --- a/litellm-rust/crates/traces-clickhouse/tests/migrations.rs +++ b/litellm-rust/crates/traces-clickhouse/tests/migrations.rs @@ -1887,10 +1887,10 @@ async fn named_and_sql_readers_share_request_log_visibility( #[case] legacy_key: Option<&str>, #[case] expected: Vec<&str>, ) -> TestResult { - use litellm_traces_clickhouse::query::named::{ - ReadAccessParams, SpendByResponseIds, SpendByResponseIdsParams, + use litellm_traces_clickhouse::{ + QueryReaders, QueryScope, + query::named::{ReadAccessParams, SpendByResponseIds, SpendByResponseIdsParams}, }; - use litellm_traces_clickhouse::{QueryReaders, QueryScope}; let database = database?; let writer = Connection::writer(&database.url)?;