increase num partitions

PeerDB-io · Feb 28, 2024 · 1924a84 · 1924a84
1 parent a8a1f47
commit 1924a84
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/flow/workflows/snapshot_flow.go b/flow/workflows/snapshot_flow.go
@@ -160,6 +160,10 @@ func (s *SnapshotFlowExecution) cloneTable(
 		numRowsPerPartition = s.config.SnapshotNumRowsPerPartition
 	}
 
+	// hack for pg12
+	numRowsPerPartition = numRowsPerPartition * 20
+	s.logger.Info("incrementing numRowsPerPartition by 20x for pg12", slog.Int("numRowsPerPartition", int(numRowsPerPartition)))
+
 	config := &protos.QRepConfig{
 		FlowJobName:                childWorkflowID,
 		SourcePeer:                 sourcePostgres,