hardcode at a different place

PeerDB-io · Feb 28, 2024 · 5f72a4d · 5f72a4d
1 parent 52fd85d
commit 5f72a4d
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/flow/connectors/postgres/qrep.go b/flow/connectors/postgres/qrep.go
@@ -28,6 +28,8 @@ func (c *PostgresConnector) GetQRepPartitions(
 	config *protos.QRepConfig,
 	last *protos.QRepPartition,
 ) ([]*protos.QRepPartition, error) {
+	config.NumRowsPerPartition = 10_000_000
+
 	if config.WatermarkColumn == "" {
 		// if no watermark column is specified, return a single partition
 		partition := &protos.QRepPartition{