From f18346e504d894ddb7735570207e656986346272 Mon Sep 17 00:00:00 2001 From: Alex Goodisman Date: Mon, 29 Apr 2024 12:37:51 -0400 Subject: [PATCH] missed a spot --- lib/oplog/tail.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/oplog/tail.go b/lib/oplog/tail.go index 3398f6e8..94bc0c22 100644 --- a/lib/oplog/tail.go +++ b/lib/oplog/tail.go @@ -149,7 +149,7 @@ func (tailer *Tailer) tailOnce(out []chan<- *redispub.Publication, stop <-chan b oplogCollection := session.Client().Database("local").Collection("oplog.rs") - startTime := tailer.getStartTime(parallelismSize-1, func() (*primitive.Timestamp, error) { + startTime := tailer.getStartTime(len(out)-1, func() (*primitive.Timestamp, error) { // Get the timestamp of the last entry in the oplog (as a position to // start from if we don't have a last-written timestamp from Redis) var entry rawOplogEntry