diff --git a/openraft/src/core/raft_core.rs b/openraft/src/core/raft_core.rs index 2fec1e589..183fd4bb0 100644 --- a/openraft/src/core/raft_core.rs +++ b/openraft/src/core/raft_core.rs @@ -1354,12 +1354,15 @@ impl, S: RaftStorage> RaftCore>(&[]).await?; + // TODO: A leader may have stepped down. + if self.engine.internal_server_state.is_leading() { + self.engine.replication_handler().update_progress(target, id, result); + self.run_engine_commands::>(&[]).await?; + } Ok(()) }