From 7b2a4d2c72ad52edcb35563999697625da09f157 Mon Sep 17 00:00:00 2001 From: NexVeridian Date: Thu, 12 Jun 2025 14:29:41 -0700 Subject: [PATCH] chore: clippy --- src/main.rs | 4 ++-- src/util.rs | 6 +++--- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/src/main.rs b/src/main.rs index 84532d5..f3f9a07 100644 --- a/src/main.rs +++ b/src/main.rs @@ -31,7 +31,7 @@ fn print_df(ticker: &Ticker, df: &DataFrame) { fn csv_merge() -> Result<(), Error> { for ticker in Ticker::iter() { - if !std::path::Path::new(&format!("./data/csv/{}", ticker)).exists() { + if !std::path::Path::new(&format!("./data/csv/{ticker}")).exists() { continue; } @@ -46,7 +46,7 @@ fn csv_merge() -> Result<(), Error> { } fn ark_plan(ticker: Ticker) -> Result<(), Error> { - println!("Starting: {:#?}", ticker); + println!("Starting: {ticker:#?}"); let sec = Duration::from_secs(rand::rng().random_range(30 * 60..=4 * 60 * 60)); // sleep(sec).await; thread::sleep(sec); diff --git a/src/util.rs b/src/util.rs index 43dfa37..709e116 100644 --- a/src/util.rs +++ b/src/util.rs @@ -110,8 +110,8 @@ impl Ark { fn read_parquet(ticker: &Ticker, path: Option<&String>) -> Result { let df = LazyFrame::scan_parquet( match path { - Some(p) => format!("{}/{}.parquet", p, ticker), - None => format!("data/parquet/{}.parquet", ticker), + Some(p) => format!("{p}/{ticker}.parquet"), + None => format!("data/parquet/{ticker}.parquet"), }, ScanArgsParquet::default(), )?; @@ -558,7 +558,7 @@ impl Ark { pub fn merge_old_csv_to_parquet(ticker: Ticker, path: Option) -> Result { let mut dfs = vec![]; - for x in glob(&format!("data/csv/{}/*", ticker))?.filter_map(Result::ok) { + for x in glob(&format!("data/csv/{ticker}/*"))?.filter_map(Result::ok) { dfs.push(LazyCsvReader::new(x).finish()?); }