feat: address v2 test with multiple addresses, add async yields (#1719)

* feat: address v2 test with multiple addresses, add async yields

* enhance address creation logic to support multiple addresses
* add `tokio::task::yield_now()` in async loops to improve responsiveness

* refactor: remove commented debug print statements from test_indexer

Author: sergeytimoshin

forester-utils/src/utils.rs

@@ -68,6 +68,8 @@ pub async fn wait_for_indexer<R: RpcConnection, I: Indexer<R>>(
             "waiting for indexer to catch up, rpc_slot: {}, indexer_slot: {}",
             rpc_slot, indexer_slot
         );
+
+        tokio::task::yield_now().await;
         sleep(std::time::Duration::from_millis(400)).await;
         indexer_slot = indexer.get_indexer_slot(rpc).await.map_err(|e| {
             error!("failed to get indexer slot from indexer: {:?}", e);

forester/src/epoch_manager.rs

@@ -484,6 +484,7 @@ impl<R: RpcConnection, I: Indexer<R> + IndexerType<R>> EpochManager<R, I> {
                         e
                     );
                     if attempt < max_retries - 1 {
+                        tokio::task::yield_now().await;
                         sleep(retry_delay).await;
                     } else {
                         if let Err(alert_err) = send_pagerduty_alert(
@@ -1257,6 +1258,7 @@ pub async fn run_service<R: RpcConnection, I: Indexer<R> + IndexerType<R>>(
                         retry_count += 1;
                         if retry_count < config.retry_config.max_retries {
                             debug!("Retrying in {:?}", retry_delay);
+                            tokio::task::yield_now().await;
                             sleep(retry_delay).await;
                             retry_delay = std::cmp::min(retry_delay * 2, MAX_RETRY_DELAY);
                         } else {

forester/src/slot_tracker.rs

@@ -70,6 +70,7 @@ impl SlotTracker {
                 }
                 Err(e) => error!("Failed to get slot: {:?}", e),
             }
+            tokio::task::yield_now().await;
             tokio::time::sleep(self.update_interval).await;
         }
     }
@@ -105,6 +106,7 @@ pub async fn wait_until_slot_reached<R: RpcConnection>(
             current_estimated_slot,
             sleep_duration.as_secs_f64()
         );
+        tokio::task::yield_now().await;
         sleep(sleep_duration).await;
     }
 

forester/src/smart_transaction.rs

@@ -71,6 +71,7 @@ pub async fn poll_transaction_confirmation<'a, R: RpcConnection>(
                 }
             }
             None => {
+                tokio::task::yield_now().await;
                 sleep(interval).await;
             }
         }