fix: check the VO from the task queues before submitting pilots

aldbr · Feb 29, 2024 · 5c3f364 · 5c3f364
1 parent ae56101
commit 5c3f364
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/DIRAC/WorkloadManagementSystem/Agent/SiteDirector.py b/src/DIRAC/WorkloadManagementSystem/Agent/SiteDirector.py
@@ -423,10 +423,12 @@ def _getNumberOfJobsNeedingPilots(self, waitingPilots: int, queue: str):
             return 0
         taskQueueDict = result["Value"]
 
-        # Get the number of jobs that would match the capability of the CE
+        # Get the number of jobs that would match the capability of the CE and the VO
         waitingSupportedJobs = 0
         for tq in taskQueueDict.values():
-            waitingSupportedJobs += tq["Jobs"]
+            ownerGroup = tq.get("OwnerGroup", "")
+            if Registry.getVOForGroup(ownerGroup) == self.vo:
+                waitingSupportedJobs += tq["Jobs"]
 
         # Get the number of jobs that need pilots
         return max(0, waitingSupportedJobs - waitingPilots)