Merge pull request #699 from chainbound/jonas/fix/flaky-test

fix(sidecar): flaky head tracker test

bolt-sidecar/src/common/backoff.rs

@@ -177,6 +177,7 @@ mod tests {
     }
 
     #[tokio::test]
+    #[ignore = "Flaky test, jitter can influence outcome"]
     async fn test_exponential_backoff_timing() {
         let counter = Arc::new(Mutex::new(Counter::new(3))); // Fail 3 times, succeed on 4th
         let start_time = Instant::now();

bolt-sidecar/src/state/head_tracker.rs

@@ -3,7 +3,7 @@ use beacon_api_client::Topic;
 use futures::StreamExt;
 use std::time::Duration;
 use tokio::{sync::broadcast, task::AbortHandle, time::sleep};
-use tracing::warn;
+use tracing::{trace, warn};
 
 use crate::client::BeaconClient;
 
@@ -42,6 +42,7 @@ impl HeadTracker {
 
         let task = tokio::spawn(async move {
             loop {
+                trace!(endpoint = %beacon_client.endpoint, "Subscribing to new head events...");
                 let mut event_stream = match beacon_client.get_events::<NewHeadsTopic>().await {
                     Ok(events) => events,
                     Err(err) => {
@@ -51,6 +52,8 @@ impl HeadTracker {
                     }
                 };
 
+                trace!(endpoint = %beacon_client.endpoint, "Subscribed to new head events");
+
                 let event = match event_stream.next().await {
                     Some(Ok(event)) => event,
                     Some(Err(err)) => {

bolt-sidecar/src/test_util.rs

@@ -34,7 +34,7 @@ use crate::{
 const EXECUTION_API_URL: &str = "https://geth-holesky.bolt.chainbound.io";
 
 /// The URL of the test beacon client HTTP API.
-const BEACON_API_URL: &str = "https://lighthouse-holesky.bolt.chainbound.io";
+const BEACON_API_URL: &str = "http://remotebeast:44400";
 
 /// The URL of the test engine client HTTP API.
 ///