diff --git a/src/python/WMComponent/JobSubmitter/JobSubmitterPoller.py b/src/python/WMComponent/JobSubmitter/JobSubmitterPoller.py index e64b06544f..c0fedac4ff 100644 --- a/src/python/WMComponent/JobSubmitter/JobSubmitterPoller.py +++ b/src/python/WMComponent/JobSubmitter/JobSubmitterPoller.py @@ -639,6 +639,11 @@ def _getJobSubmitCondition(self, jobPrio, siteName, jobType): totalJobThreshold = totalPendingThreshold + totalRunningSlots totalTaskTheshold = taskPendingThreshold + taskRunningSlots + # Bypass NoPendingSlot limit for job type (Merge) + # These jobs should not be blocked by pending slot limits + if jobType == 'Merge': + totalPendingThreshold = float('inf') + jobStats = [{"Condition": "NoPendingSlot", "Current": totalPendingJobs, "Threshold": totalPendingThreshold},