diff --git a/plugin/src/executors/tx.rs b/plugin/src/executors/tx.rs index d9622de32..45d909335 100644 --- a/plugin/src/executors/tx.rs +++ b/plugin/src/executors/tx.rs @@ -86,6 +86,7 @@ impl TxExecutor { // Exit early if we are not in the worker pool. let r_pool_positions = self.observers.network.pool_positions.read().await; let thread_pool = r_pool_positions.thread_pool.clone(); + info!("Pool position: {:#?}", thread_pool.current_position); drop(r_pool_positions); if thread_pool.current_position.is_none() && !thread_pool.workers.is_empty() { return Err(GeyserPluginError::Custom( diff --git a/plugin/src/observers/network.rs b/plugin/src/observers/network.rs index 4a560da9c..7a6384892 100644 --- a/plugin/src/observers/network.rs +++ b/plugin/src/observers/network.rs @@ -1,5 +1,3 @@ -use log::info; - use { crate::config::PluginConfig, clockwork_client::network::objects::{Pool, Registry, Snapshot, SnapshotFrame, Worker}, @@ -84,8 +82,6 @@ impl NetworkObserver { _ => {} } - info!("Pool positions: {}", w_pool_positions); - drop(w_pool_positions); Ok(()) })