DAR-CORE-CWS: Observed multiple jobs running on worker configured to …

…run at most 1.

cws-engine-service/src/main/java/jpl/cws/engine/WorkerService.java

@@ -724,6 +724,20 @@ public List<Map<String,Object>> claimWithCounter(String limitToProcDefKey) {
 
 				int queryLimit = Math.min(MaxNumForProcsOnWorker, workerMaxProcQueryLimit);
 
+				// Adjust queryLimitForProcSet to ensure total claimed won't exceed workerMaxProcQueryLimit
+				int totalPossibleClaims = 0;
+				for (Integer limit : queryLimitForProcSet.values()) {
+					totalPossibleClaims += limit;
+				}
+				if (totalPossibleClaims > queryLimit) {
+					// Scale down individual limits proportionally
+					double scaleFactor = (double)queryLimit / totalPossibleClaims;
+					for (Map.Entry<String,Integer> entry : queryLimitForProcSet.entrySet()) {
+						int newLimit = Math.max(1, (int)(entry.getValue() * scaleFactor));
+						queryLimitForProcSet.put(entry.getKey(), Math.min(newLimit, queryLimit));
+					}
+				}
+
 				Map<String,List<String>> claimRowData =
 					schedulerDbService.claimHighestPriorityStartReq(
 						workerId, currentCounts, queryLimitForProcSet, queryLimit); // pass list of procDefkey and a map of queryLimit per procDefKey