Merge pull request #8267 from fstagni/90_fixes17

[9.0] fix: there can be jobs to 'Multiple'

Author: fstagni

src/DIRAC/WorkloadManagementSystem/Agent/StatesAccountingAgent.py

@@ -135,8 +135,15 @@ def execute(self):
             for backend in self.datastores:
                 if backend.lower() == "monitoring":
                     site_name = rD["Site"]
-                    rD["Tier"] = site_metadata[site_name]["Tier"]
-                    rD["Type"] = site_metadata[site_name]["Type"]
+                    if site_name not in site_metadata:
+                        self.log.warn(
+                            f"Site {site_name} not found in site metadata, using default values",
+                        )
+                        rD["Tier"] = "4"
+                        rD["Type"] = site_name.split(".")[0]
+                    else:
+                        rD["Tier"] = site_metadata[site_name]["Tier"]
+                        rD["Type"] = site_metadata[site_name]["Type"]
                     rD["timestamp"] = int(TimeUtilities.toEpochMilliSeconds(now))
                     self.datastores["Monitoring"].addRecord(rD)
 

src/DIRAC/WorkloadManagementSystem/Utilities/JobParameters.py

@@ -2,7 +2,7 @@
 
 import multiprocessing
 
-from DIRAC import gConfig, gLogger, S_OK
+from DIRAC import S_OK, gConfig, gLogger
 from DIRAC.Core.Utilities.List import fromChar
 
 

src/DIRAC/WorkloadManagementSystem/Utilities/PilotWrapper.py

@@ -417,6 +417,8 @@ def getPilotFilesCompressedEncodedDict(pilotFiles, proxy=None):
         from DIRAC.Core.Security.ProxyFile import writeChainToTemporaryFile  # pylint: disable=import-error
 
         retVal = writeChainToTemporaryFile(proxy)
+        if not retVal["OK"]:
+            raise RuntimeError("Failed to write proxy to temporary file: %s" % retVal["Message"])
         proxyLocation = Path(retVal["Value"])
         proxy_string = proxyLocation.read_text()
         proxyLocation.unlink()