From 5cfbb8386d50a0500dbdc8b0132e1b7ffbe3559f Mon Sep 17 00:00:00 2001 From: Christian Kamm Date: Fri, 24 Nov 2023 11:04:59 +0100 Subject: [PATCH] liquidator: fix token info for same-name, fix delays (#795) (cherry picked from commit 0483faef1e58475874bd606e34a9ffa284dbc154) --- bin/liquidator/src/main.rs | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/bin/liquidator/src/main.rs b/bin/liquidator/src/main.rs index 2ee413d78..940c9cffd 100644 --- a/bin/liquidator/src/main.rs +++ b/bin/liquidator/src/main.rs @@ -499,11 +499,11 @@ async fn main() -> anyhow::Result<()> { let token_swap_info_job = tokio::spawn({ // TODO: configurable interval let mut interval = tokio::time::interval(Duration::from_secs(60)); - let mut min_delay = tokio::time::interval(Duration::from_secs(1)); + let mut startup_wait = tokio::time::interval(Duration::from_secs(1)); let shared_state = shared_state.clone(); async move { loop { - min_delay.tick().await; + startup_wait.tick().await; if !shared_state.read().unwrap().one_snapshot_done { continue; } @@ -512,10 +512,11 @@ async fn main() -> anyhow::Result<()> { let token_indexes = token_swap_info_updater .mango_client() .context - .token_indexes_by_name - .values() + .tokens + .keys() .copied() .collect_vec(); + let mut min_delay = tokio::time::interval(Duration::from_secs(1)); for token_index in token_indexes { min_delay.tick().await; match token_swap_info_updater.update_one(token_index).await {