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

Improve backfill error logging

Browse Source 
Signed-off-by: Nikolaos Karaolidis <nick@karaolidis.com>
This commit is contained in:
Nick Karaolidis
2024-03-10 19:51:41 +00:00
parent 8c7ee3d12d
commit 2de86b46f7
2 changed files with 16 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/threads/data/backfill/bars.rs
View File

@@ -124,7 +124,7 @@ impl super::Handler for Handler {
let mut next_page_token = None;
loop {
let Ok(message) = alpaca::api::incoming::bar::get(
let message = alpaca::api::incoming::bar::get(
&self.config.alpaca_client,
&self.config.alpaca_rate_limiter,
self.data_url,
@@ -136,11 +136,14 @@ impl super::Handler for Handler {
),
None,
)
.await
else {
error!("Failed to backfill bars for {:?}.", symbols);
.await;
if let Err(err) = message {
error!("Failed to backfill bars for {:?}: {:?}.", symbols, err);
return;
};
}
let message = message.unwrap();
for (symbol, bar_vec) in message.bars {
if let Some(last) = bar_vec.last() {

13
src/threads/data/backfill/news.rs
View File

@@ -86,7 +86,7 @@ impl super::Handler for Handler {
let mut next_page_token = None;
loop {
let Ok(message) = alpaca::api::incoming::news::get(
let message = alpaca::api::incoming::news::get(
&self.config.alpaca_client,
&self.config.alpaca_rate_limiter,
&alpaca::api::outgoing::news::News {
@@ -99,11 +99,14 @@ impl super::Handler for Handler {
},
None,
)
.await
else {
error!("Failed to backfill news for {:?}.", symbols);
.await;
if let Err(err) = message {
error!("Failed to backfill news for {:?}: {:?}.", symbols, err);
return;
};
}
let message = message.unwrap();
for news_item in message.news {
let news_item = News::from(news_item);