Merge pull request #785 from chaen/WMSAdministratorClient

Reintroduce WMSAdministratorClient

Author: fstagni

src/WebAppDIRAC/WebApp/handler/JobMonitorHandler.py

@@ -9,6 +9,8 @@
 from DIRAC.WorkloadManagementSystem.Client.JobMonitoringClient import JobMonitoringClient
 from DIRAC.WorkloadManagementSystem.Client.JobManagerClient import JobManagerClient
 from DIRAC.WorkloadManagementSystem.Client.PilotManagerClient import PilotManagerClient
+from DIRAC.WorkloadManagementSystem.Client.WMSAdministratorClient import WMSAdministratorClient
+
 from DIRAC.WorkloadManagementSystem.Client.SandboxStoreClient import SandboxStoreClient
 
 from WebAppDIRAC.Lib.WebHandler import WebHandler, WErr
@@ -375,12 +377,12 @@ def web_jobData(self, id: int, data_kind: str) -> dict:
                 return {"success": "false", "error": "StagerReport not available"}
             return {"success": "false", "error": result["Message"]}
         if data_kind == "getPilotStdOut":
-            if not (result := WebAppClient().getJobPilotOutput(id))["OK"]:
+            if not (result := WMSAdministratorClient().getJobPilotOutput(id))["OK"]:
                 return {"success": "false", "error": result["Message"]}
             if "StdOut" in result["Value"]:
                 return {"success": "true", "result": result["Value"]["StdOut"]}
         if data_kind == "getPilotStdErr":
-            if not (result := WebAppClient().getJobPilotOutput(id))["OK"]:
+            if not (result := WMSAdministratorClient().getJobPilotOutput(id))["OK"]:
                 return {"success": "false", "error": result["Message"]}
             if "StdErr" in result["Value"]:
                 return {"success": "true", "result": result["Value"]["StdErr"]}