changed max rows for Events ETL

jallentxbiomed · jallentxbiomed · commit ae3ad74f6bb3 · 2025-03-20T10:47:59.000-05:00
diff --git a/snd/src/org/labkey/snd/query/EventsTable.java b/snd/src/org/labkey/snd/query/EventsTable.java
@@ -146,10 +146,12 @@ public int mergeRows(User user, Container container, DataIteratorBuilder rows, B
             Set<Integer> eventIds = handleNarrativeCache(rows, configParameters, errors);
 
             int result = 0;
+            int maxMergeRows = SNDManager.MAX_MERGE_ROWS * 10;
+
             // Large merge triggers importRows path
-            if (eventIds.size() > SNDManager.MAX_MERGE_ROWS)
+            if (eventIds.size() > maxMergeRows)
             {
-                log.info("More than " + SNDManager.MAX_MERGE_ROWS + " rows. using importRows method.");
+                log.info("More than " + maxMergeRows + " rows. using importRows method.");
                 result = super.importRows(user, container, rows, errors, configParameters, extraScriptContext);
             }
             else

Original file line number	Diff line number	Diff line change
`@@ -146,10 +146,12 @@ public int mergeRows(User user, Container container, DataIteratorBuilder rows, B`
`146`	`146`	`Set<Integer> eventIds = handleNarrativeCache(rows, configParameters, errors);`
`147`	`147`
`148`	`148`	`int result = 0;`
	`149`	`+ int maxMergeRows = SNDManager.MAX_MERGE_ROWS * 10;`
	`150`	`+`
`149`	`151`	`// Large merge triggers importRows path`
`150`		`- if (eventIds.size() > SNDManager.MAX_MERGE_ROWS)`
	`152`	`+ if (eventIds.size() > maxMergeRows)`
`151`	`153`	`{`
`152`		`- log.info("More than " + SNDManager.MAX_MERGE_ROWS + " rows. using importRows method.");`
	`154`	`+ log.info("More than " + maxMergeRows + " rows. using importRows method.");`
`153`	`155`	`result = super.importRows(user, container, rows, errors, configParameters, extraScriptContext);`
`154`	`156`	`}`
`155`	`157`	`else`