fix: remove OwnerDN from SiteDirector & PilotStatus

DIRACGrid · Sep 21, 2023 · b9ef772 · b9ef772
1 parent 21634fb
commit b9ef772
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 11 deletions.
diff --git a/src/DIRAC/WorkloadManagementSystem/Agent/PilotStatusAgent.py b/src/DIRAC/WorkloadManagementSystem/Agent/PilotStatusAgent.py
@@ -190,16 +190,7 @@ def _addPilotsAccountingReport(self, pilotsData):
             pA = PilotAccounting()
             pA.setEndTime(pData["LastUpdateTime"])
             pA.setStartTime(pData["SubmissionTime"])
-            retVal = Registry.getUsernameForDN(pData["OwnerDN"])
-            if not retVal["OK"]:
-                userName = "unknown"
-                self.log.error(
-                    "Can't determine username for dn",
-                    f": {pData['OwnerDN']} : {retVal['Message']}",
-                )
-            else:
-                userName = retVal["Value"]
-            pA.setValueByKey("User", userName)
+            pA.setValueByKey("User", "unknown")
             pA.setValueByKey("UserGroup", pData["OwnerGroup"])
             result = getCESiteMapping(pData["DestinationSite"])
             if result["OK"] and pData["DestinationSite"] in result["Value"]:

diff --git a/src/DIRAC/WorkloadManagementSystem/Agent/SiteDirector.py b/src/DIRAC/WorkloadManagementSystem/Agent/SiteDirector.py
@@ -1338,7 +1338,7 @@ def sendPilotAccounting(self, pilotDict):
             pA = PilotAccounting()
             pA.setEndTime(pilotDict[pRef]["LastUpdateTime"])
             pA.setStartTime(pilotDict[pRef]["SubmissionTime"])
-            retVal = Registry.getUsernameForDN(pilotDict[pRef]["OwnerDN"])
+            retVal = Registry.getUsernameForDN(self.pilotDN)
             if not retVal["OK"]:
                 username = "unknown"
                 self.log.error("Can't determine username for dn", pilotDict[pRef]["OwnerDN"])