fix: Fixing plotter for pilotsubm accounting

Author: rupozzi

src/DIRAC/AccountingSystem/private/Plotters/PilotSubmissionPlotter.py

@@ -34,12 +34,7 @@ def _reportSubmission(self, reportRequest):
             return retVal
         dataDict, granularity = retVal["Value"]
         self.stripDataField(dataDict, 0)
-        dataDict, _ = self._divideByFactor(dataDict, granularity)
-        dataDict = self._fillWithZero(granularity, reportRequest["startTime"], reportRequest["endTime"], dataDict)
-        baseDataDict, graphDataDict, _, unit = self._findSuitableRateUnit(
-            dataDict, self._getAccumulationMaxValue(dataDict), "jobs"
-        )
-        return S_OK({"data": baseDataDict, "graphDataDict": graphDataDict, "granularity": granularity, "unit": unit})
+        return S_OK({"data": dataDict, "granularity": granularity})
 
     def _plotSubmission(self, reportRequest, plotInfo, filename):
         """
@@ -55,9 +50,15 @@ def _plotSubmission(self, reportRequest, plotInfo, filename):
             "starttime": reportRequest["startTime"],
             "endtime": reportRequest["endTime"],
             "span": plotInfo["granularity"],
-            "ylabel": plotInfo["unit"],
+            "ylabel": "Submissions",
         }
-        return self._generateTimedStackedBarPlot(filename, plotInfo["graphDataDict"], metadata)
+        plotInfo["data"] = self._fillWithZero(
+            granularity=plotInfo["granularity"],
+            startEpoch=reportRequest["startTime"],
+            endEpoch=reportRequest["endTime"],
+            dataDict=plotInfo["data"],
+        )
+        return self._generateTimedStackedBarPlot(filename, plotInfo["data"], metadata)
 
     _reportSubmissionEfficiencyName = "Submission efficiency"
 

src/DIRAC/MonitoringSystem/Client/MonitoringReporter.py

@@ -165,18 +165,6 @@ def commit(self):
             self.__documentLock.release()
         return S_OK(recordSent)
 
-    def delayedCommit(self):
-        """
-        If needed start a timer that will run the commit later
-        allowing to send more registers at once (reduces overheads).
-        """
-
-        if not self.__commitTimer.is_alive():
-            self.__commitTimer = threading.Timer(5, self.commit)
-            self.__commitTimer.start()
-
-        return S_OK()
-
     def __getProducer(self):
         """
         This method is used to get the default MQ producer or create it if needed.

src/DIRAC/WorkloadManagementSystem/Agent/SiteDirector.py

@@ -1423,7 +1423,7 @@ def sendPilotSubmissionMonitoring(self, siteName, ceName, queueName, numTotal, n
         pilotMonitoringReporter.addRecord(pilotMonitoringData)
 
         self.log.verbose("Committing pilot submission to monitoring")
-        result = pilotMonitoringReporter.delayedCommit()
+        result = pilotMonitoringReporter.commit()
         if not result["OK"]:
             self.log.error("Could not commit pilot submission to monitoring", result["Message"])
             return S_ERROR()