fix: JobReport cannot commit job params from the JobWrapper

Author: aldbr

src/DIRAC/Resources/Computing/ComputingElement.py

@@ -52,7 +52,7 @@
     getNumberOfProcessors,
 )
 
-INTEGER_PARAMETERS = ["CPUTime", "NumberOfProcessors", "NumberOfPayloadProcessors", "MaxRAM"]
+INTEGER_PARAMETERS = ["CPUTime", "CPUNormalizationFactor", "NumberOfProcessors", "NumberOfPayloadProcessors", "MaxRAM"]
 FLOAT_PARAMETERS = ["WaitingToRunningRatio"]
 LIST_PARAMETERS = ["Tag", "RequiredTag"]
 WAITING_TO_RUNNING_RATIO = 0.5

src/DIRAC/WorkloadManagementSystem/Client/JobReport.py

@@ -115,16 +115,20 @@ def sendStoredJobParameters(self):
 
     def commit(self):
         """Send all the accumulated information"""
+        messages = []
 
-        success = True
         result = self.sendStoredStatusInfo()
-        success &= result["OK"]
+        if not result["OK"]:
+            messages.append(result["Message"])
         result = self.sendStoredJobParameters()
-        success &= result["OK"]
+        if not result["OK"]:
+            messages.append(result["Message"])
 
-        if success:
-            return S_OK()
-        return S_ERROR("Information upload to JobStateUpdate service failed")
+        if messages:
+            gLogger.warn("Some information could not be uploaded to JobStateUpdate service:", "; ".join(messages))
+            return S_ERROR("Information upload to JobStateUpdate service failed")
+
+        return S_OK()
 
     def dump(self):
         """Print out the contents of the internal cached information"""