fix assert

risingwavelabs · Feb 26, 2024 · 78aa155 · 78aa155
1 parent b501998
commit 78aa155
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/meta/src/barrier/mod.rs b/src/meta/src/barrier/mod.rs
@@ -302,9 +302,9 @@ impl CheckpointControl {
                         CompletingCommand::None | CompletingCommand::Err(_) => None,
                         CompletingCommand::Completing { command_ctx, .. } => Some(command_ctx),
                     }
-                    .iter()
+                    .into_iter()
                 )
-                .any(|x| x.command_ctx.command.should_pause_inject_barrier()),
+                .any(|command_ctx| command_ctx.command.should_pause_inject_barrier()),
             should_pause
         );