diff --git a/flow/workflows/snapshot_flow.go b/flow/workflows/snapshot_flow.go index ae052838c7..8d2ee29d74 100644 --- a/flow/workflows/snapshot_flow.go +++ b/flow/workflows/snapshot_flow.go @@ -160,10 +160,6 @@ 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,