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()?); }