karaolidis/qrust
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix panic when fetching bars

Browse Source 
Signed-off-by: Nikolaos Karaolidis <nick@karaolidis.com>
This commit is contained in:
Nick Karaolidis
2023-09-09 19:13:34 +03:00
parent e26d2b95e7
commit c57eb7567c
2 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/config.rs
View File

@@ -51,8 +51,8 @@ impl Config {
.build() .build()
.unwrap(), .unwrap(),
alpaca_rate_limit: RateLimiter::direct(Quota::per_minute(match alpaca_source { alpaca_rate_limit: RateLimiter::direct(Quota::per_minute(match alpaca_source {
Source::Iex => NonZeroU32::new(200).unwrap(), Source::Iex => NonZeroU32::new(180).unwrap(),
Source::Sip => NonZeroU32::new(1000).unwrap(), Source::Sip => NonZeroU32::new(900).unwrap(),
})), })),
alpaca_historical_offset: Duration::from_secs(match alpaca_source { alpaca_historical_offset: Duration::from_secs(match alpaca_source {
Source::Iex => 900, Source::Iex => 900,

7
src/data/historical.rs
View File

@@ -91,7 +91,12 @@ pub async fn backfill(
break; break;
}; };
for bar in response.bars.remove(&asset.symbol).unwrap().unwrap() { for bar in response
.bars
.remove(&asset.symbol)
.unwrap_or_default()
.unwrap_or_default()
{
bars.insert(bar.timestamp, Bar::from((bar, asset.symbol.clone()))); bars.insert(bar.timestamp, Bar::from((bar, asset.symbol.clone())));
} }