magnus167/msyrs
1
0
Fork 0
mirror of https://github.com/Magnus167/msyrs.git synced 2025-08-20 13:00:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

working...

Browse Source
This commit is contained in:
Palash Tyagi 2024-11-09 22:21:17 +00:00
parent b7bccf342d
commit fe1c348dc7
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/download/jpmaqsdownload.rs
View File

@ -129,7 +129,7 @@ impl JPMaQSDownload {
// .map(|tsv| JPMaQSIndicator::new(tsv)) // .map(|tsv| JPMaQSIndicator::new(tsv))
// .collect::<Result<Vec<JPMaQSIndicator>, Box<dyn Error>>>()?; // .collect::<Result<Vec<JPMaQSIndicator>, Box<dyn Error>>>()?;
let indicators: Vec<_> = dqts_vec let indicators: Vec<_> = dqts_vec
.par_iter() .into_par_iter() // Use into_par_iter() to parallelize and consume dqts_vec
.flat_map(|dqts| { .flat_map(|dqts| {
dqts.get_timeseries_by_ticker() dqts.get_timeseries_by_ticker()
.into_par_iter() .into_par_iter()

2
src/download/requester.rs
View File

@ -18,7 +18,7 @@ const TIMESERIES_ENDPOINT: &str = "/expressions/time-series";
const CATALOGUE_ENDPOINT: &str = "/group/instruments"; const CATALOGUE_ENDPOINT: &str = "/group/instruments";
const API_DELAY_MILLIS: u64 = 200; const API_DELAY_MILLIS: u64 = 200;
const MAX_THREAD_WORKERS: usize = 20; const MAX_THREAD_WORKERS: usize = 100;
// const JPMAQS_CATALOGUE_GROUP: &str = "JPMAQS"; // const JPMAQS_CATALOGUE_GROUP: &str = "JPMAQS";
#[derive(Debug, Clone)] #[derive(Debug, Clone)]