From d7e4991026383e6da0febf39b17fa345a780c0e3 Mon Sep 17 00:00:00 2001 From: aldbr Date: Mon, 22 Jan 2024 16:29:50 +0100 Subject: [PATCH] feat: remove RemoteRunner from Script --- src/DIRAC/Workflow/Modules/Script.py | 24 +++++++----------------- 1 file changed, 7 insertions(+), 17 deletions(-) diff --git a/src/DIRAC/Workflow/Modules/Script.py b/src/DIRAC/Workflow/Modules/Script.py index 9954ea2fe7e..651b942ef30 100644 --- a/src/DIRAC/Workflow/Modules/Script.py +++ b/src/DIRAC/Workflow/Modules/Script.py @@ -10,7 +10,6 @@ from DIRAC import gLogger, gConfig from DIRAC.Core.Utilities.Subprocess import systemCall -from DIRAC.WorkloadManagementSystem.Utilities.RemoteRunner import RemoteRunner from DIRAC.Workflow.Modules.ModuleBase import ModuleBase @@ -83,22 +82,13 @@ def _executeCommand(self): """execute the self.command (uses systemCall)""" failed = False - # Check whether the execution should be done remotely - if gConfig.getValue("/LocalSite/RemoteExecution", False): - remoteRunner = RemoteRunner( - gConfig.getValue("/LocalSite/Site"), - gConfig.getValue("/LocalSite/GridCE"), - gConfig.getValue("/LocalSite/CEQueue"), - ) - retVal = remoteRunner.execute(self.command) - else: - retVal = systemCall( - timeout=0, - cmdSeq=shlex.split(self.command), - env=self.environment, - callbackFunction=self.callbackFunction, - bufferLimit=self.bufferLimit, - ) + retVal = systemCall( + timeout=0, + cmdSeq=shlex.split(self.command), + env=self.environment, + callbackFunction=self.callbackFunction, + bufferLimit=self.bufferLimit, + ) if not retVal["OK"]: failed = True