From 7f0869824d8e5aa99549026f8f9360bd8e6c4343 Mon Sep 17 00:00:00 2001 From: Federico Stagni Date: Fri, 3 Jul 2026 16:10:31 +0200 Subject: [PATCH] refactor: moved pilots CE interactions RPC calls --- src/WebAppDIRAC/WebApp/handler/JobMonitorHandler.py | 2 +- src/WebAppDIRAC/WebApp/handler/PilotMonitorHandler.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/WebAppDIRAC/WebApp/handler/JobMonitorHandler.py b/src/WebAppDIRAC/WebApp/handler/JobMonitorHandler.py index a6b90454..01df6603 100644 --- a/src/WebAppDIRAC/WebApp/handler/JobMonitorHandler.py +++ b/src/WebAppDIRAC/WebApp/handler/JobMonitorHandler.py @@ -390,7 +390,7 @@ def web_jobData(self, id: int, data_kind: str) -> dict: pilotClient = PilotManagerClient() if (retVal := pilotClient.getPilots(id))["OK"]: pilotReference = list(retVal["Value"])[0] - if (retVal := pilotClient.getPilotLoggingInfo(pilotReference))["OK"]: + if (retVal := WebAppClient().getPilotLoggingInfo(pilotReference))["OK"]: return {"success": "true", "result": retVal["Value"]} return {"success": "false", "error": retVal["Message"]} return {"success": "false", "error": retVal["Message"]} diff --git a/src/WebAppDIRAC/WebApp/handler/PilotMonitorHandler.py b/src/WebAppDIRAC/WebApp/handler/PilotMonitorHandler.py index 228ce631..99cfc4eb 100644 --- a/src/WebAppDIRAC/WebApp/handler/PilotMonitorHandler.py +++ b/src/WebAppDIRAC/WebApp/handler/PilotMonitorHandler.py @@ -140,7 +140,7 @@ def __request(self): return req def web_getJobInfoData(self, data): - RPC = PilotManagerClient() + RPC = WebAppClient() if self.get_argument("data_kind") == "getPilotOutput": if (result := RPC.getPilotOutput(data))["OK"]: return {"success": "true", "result": result["Value"]["StdOut"]}