bump: tokio

Author: DaMandal0rian

chain/ethereum/src/health.rs

@@ -1,10 +1,8 @@
-
+use crate::adapter::EthereumAdapter as EthereumAdapterTrait;
+use crate::EthereumAdapter;
 use std::sync::{Arc, RwLock};
 use std::time::{Duration, Instant};
 use tokio::time::sleep;
-use crate::adapter::EthereumAdapter as EthereumAdapterTrait;
-use crate::EthereumAdapter;
-
 #[derive(Debug)]
 pub struct Health {
     pub provider: Arc<EthereumAdapter>,

chain/ethereum/src/lib.rs

@@ -1,11 +1,11 @@
-pub mod health;
 mod adapter;
 mod buffered_call_cache;
 mod capabilities;
 pub mod codec;
 mod data_source;
 mod env;
 mod ethereum_adapter;
+pub mod health;
 mod ingestor;
 mod polling_block_stream;
 pub mod runtime;

chain/ethereum/src/network.rs

@@ -277,7 +277,10 @@ impl EthereumNetworkAdapters {
         let weights: Vec<_> = input
             .iter()
             .map(|a| {
-                let health_checker = self.health_checkers.iter().find(|h| h.provider() == a.provider());
+                let health_checker = self
+                    .health_checkers
+                    .iter()
+                    .find(|h| h.provider() == a.provider());
                 let score = health_checker.map_or(1.0, |h| h.score());
                 a.weight * score
             })
@@ -861,8 +864,14 @@ mod tests {
             vec![],
         );
 
-        let always_retest_adapters =
-            EthereumNetworkAdapters::new(chain_id, manager.clone(), vec![], Some(1f64), false, vec![]);
+        let always_retest_adapters = EthereumNetworkAdapters::new(
+            chain_id,
+            manager.clone(),
+            vec![],
+            Some(1f64),
+            false,
+            vec![],
+        );
 
         assert_eq!(
             no_retest_adapters
@@ -978,8 +987,14 @@ mod tests {
             ProviderCheckStrategy::MarkAsValid,
         );
 
-        let no_retest_adapters =
-            EthereumNetworkAdapters::new(chain_id.clone(), manager, vec![], Some(0f64), false, vec![]);
+        let no_retest_adapters = EthereumNetworkAdapters::new(
+            chain_id.clone(),
+            manager,
+            vec![],
+            Some(0f64),
+            false,
+            vec![],
+        );
         assert_eq!(
             no_retest_adapters
                 .cheapest_with(&NodeCapabilities {

node/Cargo.toml

@@ -45,7 +45,7 @@ prometheus = { version = "0.14.0", features = ["push"] }
 json-structural-diff = { version = "0.2", features = ["colorize"] }
 globset = "0.4.16"
 notify = "8.0.0"
-tokio = { version = "1", features = ["full"] }
+tokio = { version = "1.47.1", features = ["full"] }
 
 [target.'cfg(unix)'.dependencies]
 pgtemp = { git = "https://github.com/graphprotocol/pgtemp", branch = "initdb-args" }

node/src/network_setup.rs

@@ -103,7 +103,7 @@ impl AdapterConfiguration {
     }
 }
 
-use graph_chain_ethereum::health::{Health, health_check_task};
+use graph_chain_ethereum::health::{health_check_task, Health};
 
 pub struct Networks {
     pub adapters: Vec<AdapterConfiguration>,
@@ -297,7 +297,11 @@ impl Networks {
             },
         );
 
-        let health_checkers: Vec<_> = eth_adapters.clone().flat_map(|(_, adapters)| adapters).map(|adapter| Arc::new(Health::new(adapter.adapter.clone()))).collect();
+        let health_checkers: Vec<_> = eth_adapters
+            .clone()
+            .flat_map(|(_, adapters)| adapters)
+            .map(|adapter| Arc::new(Health::new(adapter.adapter.clone())))
+            .collect();
         if weighted_rpc_steering {
             tokio::spawn(health_check_task(health_checkers.clone()));
         }