fix once

flow/connectors/postgres/qrep.go

@@ -92,21 +92,27 @@ func (c *PostgresConnector) getNumRowsPartitions(
 			return nil, fmt.Errorf("failed to get min max values for xmin: %w", err)
 		}
 
+		// we know these are int64s so we can just cast them
+		minValInt := maxVal.(int64)
+		maxValInt := maxVal.(int64)
+
 		// we will only return 1 partition for xmin:
 		// 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 {
-			mvInt, ok := maxVal.(int64)
-			if !ok {
-				return nil, fmt.Errorf("expected max value to be int64, got %T", maxVal)
-			}
-			minVal = mvInt + 1
+			minVal = minValInt + 1
+		}
+
+		if minValInt > maxValInt {
+			// log and return an empty partition
+			log.WithFields(log.Fields{
+				"flowName": config.FlowJobName,
+			}).Infof("xmin min value is greater than max value, returning empty partition")
+			return make([]*protos.QRepPartition, 0), nil
 		}
 
 		log.WithFields(log.Fields{
 			"flowName": config.FlowJobName,
-			"min":      minVal,
-			"max":      maxVal,
 		}).Infof("single xmin partition range: %v - %v", minVal, maxVal)
 
 		partition := &protos.QRepPartition{