chore: Log why block stream was restarted

near · Jul 18, 2024 · 9bb710d · 9bb710d
1 parent ee5845b
commit 9bb710d
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/coordinator/src/handlers/block_streams.rs b/coordinator/src/handlers/block_streams.rs
@@ -254,13 +254,17 @@ impl BlockStreamsHandler {
 
             if !stale && !stalled {
                 return Ok(());
+            } else {
+                tracing::info!(stale, stalled, "Restarting stalled block stream");
             }
+        } else {
+            tracing::info!("Restarting stalled block stream");
         }
 
-        tracing::info!("Restarting stalled block stream");
-
         self.stop(block_stream.stream_id.clone()).await?;
-        self.resume_block_stream(config).await?;
+
+        let height = self.get_continuation_block_height(config).await?;
+        self.start(height, config).await?;
 
         Ok(())
     }