diff --git a/src/WebAppDIRAC/WebApp/handler/JobMonitorHandler.py b/src/WebAppDIRAC/WebApp/handler/JobMonitorHandler.py index 653dc415..0f8c4464 100644 --- a/src/WebAppDIRAC/WebApp/handler/JobMonitorHandler.py +++ b/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"]}