diff --git a/test/raft/replication_test.cc b/test/raft/replication_test.cc index 57b1103102..f369f0ff63 100644 --- a/test/raft/replication_test.cc +++ b/test/raft/replication_test.cc @@ -483,7 +483,7 @@ future run_test(test_case test) { std::vector values(n); std::iota(values.begin(), values.end(), next_val); std::vector commands = create_commands(values); - co_await seastar::parallel_for_each(commands, [&] (raft::command cmd) { + co_await seastar::do_for_each(commands, [&] (raft::command cmd) { tlogger.debug("Adding command entry on leader {}", leader); return rafts[leader].first->add_entry(std::move(cmd), raft::wait_type::committed); }); @@ -564,7 +564,7 @@ future run_test(test_case test) { std::iota(values.begin(), values.end(), next_val); std::vector commands = create_commands(values); tlogger.debug("Adding remaining {} entries on leader {}", values.size(), leader); - co_await seastar::parallel_for_each(commands, [&] (raft::command cmd) { + co_await seastar::do_for_each(commands, [&] (raft::command cmd) { return rafts[leader].first->add_entry(std::move(cmd), raft::wait_type::committed); }); }