clear finalization timeouts on advancee state

samliok · samliok · commit 2d9dfe62f0b6 · 2025-12-11T16:38:39.000-05:00
diff --git a/replication_state.go b/replication_state.go
@@ -245,6 +245,7 @@ func (r *ReplicationState) MaybeAdvanceState(nextSequenceToCommit uint64, curren
 
 	if nextSequenceToCommit > 0 {
 		r.deleteOldRounds(nextSequenceToCommit - 1)
+		r.finalizationRequestor.removeOldTasks(nextSequenceToCommit- 1)
 	}
 
 	// update the requestors in case they need to send more requests

Original file line number	Diff line number	Diff line change
`@@ -245,6 +245,7 @@ func (r *ReplicationState) MaybeAdvanceState(nextSequenceToCommit uint64, curren`
`245`	`245`
`246`	`246`	`if nextSequenceToCommit > 0 {`
`247`	`247`	`r.deleteOldRounds(nextSequenceToCommit - 1)`
	`248`	`+ r.finalizationRequestor.removeOldTasks(nextSequenceToCommit- 1)`
`248`	`249`	`}`
`249`	`250`
`250`	`251`	`// update the requestors in case they need to send more requests`