missed a spot

tulip · Apr 29, 2024 · f18346e · f18346e
1 parent 163729f
commit f18346e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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