correct collect error

risingwavelabs · Nov 22, 2024 · e84eb89 · e84eb89
1 parent a7d6fc2
commit e84eb89
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/meta/src/barrier/rpc.rs b/src/meta/src/barrier/rpc.rs
@@ -243,9 +243,9 @@ impl ControlStreamManager {
         let mut errors = vec![(worker_id, first_err)];
         #[cfg(not(madsim))]
         {
-            if !self.nodes.is_empty() {
+            {
                 let _ = timeout(COLLECT_ERROR_TIMEOUT, async {
-                    loop {
+                    while !self.nodes.is_empty() {
                         let (worker_id, result) = self.next_response().await;
                         if let Err(e) = result {
                             errors.push((worker_id, e));