fix checks

PeerDB-io · Oct 25, 2023 · 92a496e · 92a496e
1 parent da16389
commit 92a496e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/flow/connectors/postgres/qrep.go b/flow/connectors/postgres/qrep.go
@@ -100,7 +100,8 @@ func (c *PostgresConnector) getNumRowsPartitions(
 		// if there is no last partition, we will return a partition with the min and max values
 		// if there is a last partition, we will return a partition with the last partition's end value + 1 and the max value
 		if last != nil && last.Range != nil {
-			minVal = minValInt + 1
+			maxValInt += 1
+			minVal = minValInt
 		}
 
 		if minValInt > maxValInt {