From fe1c348dc7244c9a983a333e26572ae6eeb287bc Mon Sep 17 00:00:00 2001 From: Palash Tyagi <23239946+Magnus167@users.noreply.github.com> Date: Sat, 9 Nov 2024 22:21:17 +0000 Subject: [PATCH] working... --- src/download/jpmaqsdownload.rs | 2 +- src/download/requester.rs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/download/jpmaqsdownload.rs b/src/download/jpmaqsdownload.rs index 77d6bff..c837597 100644 --- a/src/download/jpmaqsdownload.rs +++ b/src/download/jpmaqsdownload.rs @@ -129,7 +129,7 @@ impl JPMaQSDownload { // .map(|tsv| JPMaQSIndicator::new(tsv)) // .collect::, Box>>()?; let indicators: Vec<_> = dqts_vec - .par_iter() + .into_par_iter() // Use into_par_iter() to parallelize and consume dqts_vec .flat_map(|dqts| { dqts.get_timeseries_by_ticker() .into_par_iter() diff --git a/src/download/requester.rs b/src/download/requester.rs index 9dbfe62..a41a8bd 100644 --- a/src/download/requester.rs +++ b/src/download/requester.rs @@ -18,7 +18,7 @@ const TIMESERIES_ENDPOINT: &str = "/expressions/time-series"; const CATALOGUE_ENDPOINT: &str = "/group/instruments"; const API_DELAY_MILLIS: u64 = 200; -const MAX_THREAD_WORKERS: usize = 20; +const MAX_THREAD_WORKERS: usize = 100; // const JPMAQS_CATALOGUE_GROUP: &str = "JPMAQS"; #[derive(Debug, Clone)]