From c57eb7567c9db64a4323900d6625922ec60b7b3b Mon Sep 17 00:00:00 2001 From: Nikolaos Karaolidis Date: Sat, 9 Sep 2023 19:13:34 +0300 Subject: [PATCH] Fix panic when fetching bars Signed-off-by: Nikolaos Karaolidis --- src/config.rs | 4 ++-- src/data/historical.rs | 7 ++++++- 2 files changed, 8 insertions(+), 3 deletions(-) diff --git a/src/config.rs b/src/config.rs index 9fb1f7d..4cba9b7 100644 --- a/src/config.rs +++ b/src/config.rs @@ -51,8 +51,8 @@ impl Config { .build() .unwrap(), alpaca_rate_limit: RateLimiter::direct(Quota::per_minute(match alpaca_source { - Source::Iex => NonZeroU32::new(200).unwrap(), - Source::Sip => NonZeroU32::new(1000).unwrap(), + Source::Iex => NonZeroU32::new(180).unwrap(), + Source::Sip => NonZeroU32::new(900).unwrap(), })), alpaca_historical_offset: Duration::from_secs(match alpaca_source { Source::Iex => 900, diff --git a/src/data/historical.rs b/src/data/historical.rs index 02eeb7e..b02d145 100644 --- a/src/data/historical.rs +++ b/src/data/historical.rs @@ -91,7 +91,12 @@ pub async fn backfill( 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()))); }