From 13fa2119fcbd02c9dd76a1bd81e16e559009fcd2 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?J=C4=99drzej=20Stuczy=C5=84ski?= Date: Wed, 13 Dec 2023 11:03:05 +0000 Subject: [PATCH] wip --- nym-validator-rewarder/src/main.rs | 8 ++++---- nym-validator-rewarder/src/rewarder/mod.rs | 12 +++++++++++- 2 files changed, 15 insertions(+), 5 deletions(-) diff --git a/nym-validator-rewarder/src/main.rs b/nym-validator-rewarder/src/main.rs index 921a66c2bd..f5d59b57c2 100644 --- a/nym-validator-rewarder/src/main.rs +++ b/nym-validator-rewarder/src/main.rs @@ -13,10 +13,10 @@ mod rewarder; #[tokio::main] async fn main() -> anyhow::Result<()> { - std::env::set_var( - "RUST_LOG", - "debug,tendermint_rpc=warn,h2=warn,hyper=warn,rustls=warn,reqwest=warn,tungstenite=warn,async_tungstenite=warn", - ); + // std::env::set_var( + // "RUST_LOG", + // "debug,tendermint_rpc=warn,h2=warn,hyper=warn,rustls=warn,reqwest=warn,tungstenite=warn,async_tungstenite=warn", + // ); let args = Cli::parse(); setup_env(args.config_env_file.as_ref()); diff --git a/nym-validator-rewarder/src/rewarder/mod.rs b/nym-validator-rewarder/src/rewarder/mod.rs index 27ad1564ae..a61924d1c2 100644 --- a/nym-validator-rewarder/src/rewarder/mod.rs +++ b/nym-validator-rewarder/src/rewarder/mod.rs @@ -34,7 +34,17 @@ impl Rewarder { self.nyxd_scraper.start().await?; - tokio::time::sleep(Duration::from_secs(30)).await; + tokio::time::sleep(Duration::from_secs(3000)).await; + + loop { + tokio::select! { + biased; + interrupted = task_manager.catch_interrupt() => { + todo!() + } + + } + } /* task 1: