X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;ds=sidebyside;f=nepi%2Fresources%2Flinux%2Fnode.py;h=168686c2f1e8a19fb550e0be5b5f3e06dee37932;hb=77008816b3a7de0a39ba169ffc0579135a058b98;hp=3043857993646c733cf0624dd7be2197b41611ee;hpb=10ddf71cfe290a9de4ac06fc55b8d335b94c2d52;p=nepi.git diff --git a/nepi/resources/linux/node.py b/nepi/resources/linux/node.py index 30438579..168686c2 100644 --- a/nepi/resources/linux/node.py +++ b/nepi/resources/linux/node.py @@ -299,7 +299,7 @@ class LinuxNode(ResourceManager): if out.find("Debian") == 0: self._os = OSType.DEBIAN - elif out.find("Ubuntu") ==0: + elif out.find("Ubuntu") == 0: self._os = OSType.UBUNTU elif out.find("Fedora release") == 0: self._os = OSType.FEDORA @@ -335,7 +335,7 @@ class LinuxNode(ResourceManager): @property def use_deb(self): - return (self.os & (OSType.DEBIAN|OSType.UBUNTU)) + return (self.os & (OSType.DEBIAN | OSType.UBUNTU)) @property def use_rpm(self): @@ -506,9 +506,10 @@ class LinuxNode(ResourceManager): (out, err), proc = self.execute(cmd, retry = 1, with_lock = True) - def search_for_child(self, pid, pids, ppid, family=[]): + def search_for_child(self, pid, pids, ppid, family=None): """ Recursive function to search for child. List A contains the pids and list B the parents (ppid) """ + family = family if family is not None else [] family.append(pid) for key, value in enumerate(ppid): if value == pid: @@ -766,7 +767,7 @@ class LinuxNode(ResourceManager): # create a temporal file with the content to upload # in python3 we need to open in binary mode if str is bytes mode = 'w' if isinstance(src, str) else 'wb' - f = tempfile.NamedTemporaryFile(mode=mode, delete=False) + f = tempfile.NamedTemporaryFile(mode = mode, delete = False) f.write(src) f.close() if executable: @@ -915,18 +916,18 @@ class LinuxNode(ResourceManager): return self.execute(cmd, with_lock = True) def run_and_wait(self, command, home, - shfile="cmd.sh", - env=None, - overwrite=True, - wait_run=True, - pidfile="pidfile", - ecodefile="exitcode", - stdin=None, - stdout="stdout", - stderr="stderr", - sudo=False, - tty=False, - raise_on_error=True): + shfile = "cmd.sh", + env = None, + overwrite = True, + wait_run = True, + pidfile = "pidfile", + ecodefile = "exitcode", + stdin = None, + stdout = "stdout", + stderr = "stderr", + sudo = False, + tty = False, + raise_on_error = True): """ Uploads the 'command' to a bash script in the host. Then runs the script detached in background in the host, and @@ -1008,10 +1009,10 @@ class LinuxNode(ResourceManager): return ExitCode.ERROR def upload_command(self, command, - shfile="cmd.sh", - ecodefile="exitcode", - overwrite=True, - env=None): + shfile = "cmd.sh", + ecodefile = "exitcode", + overwrite = True, + env = None): """ Saves the command as a bash script file in the remote host, and forces to save the exit code of the command execution to the ecodefile """ @@ -1021,7 +1022,7 @@ class LinuxNode(ResourceManager): # The exit code of the command will be stored in ecodefile command = " {{ {command} }} ; echo $? > {ecodefile} ;"\ - .format(command=command, ecodefile=ecodefile) + .format(command = command, ecodefile = ecodefile) # Export environment environ = self.format_environment(env) @@ -1029,9 +1030,9 @@ class LinuxNode(ResourceManager): # Add environ to command command = environ + command - return self.upload(command, shfile, text=True, overwrite=overwrite) + return self.upload(command, shfile, text = True, overwrite = overwrite) - def format_environment(self, env, inline=False): + def format_environment(self, env, inline = False): """ Formats the environment variables for a command to be executed either as an inline command (i.e. export PYTHONPATH=src/..; export LALAL= ..;python script.py) or @@ -1184,7 +1185,7 @@ class LinuxNode(ResourceManager): command = [] for d in dests: - command.append(" [ -f {dst} ] && echo '{dst}' ".format(dst=d) ) + command.append(" [ -f {dst} ] && echo '{dst}' ".format(dst = d) ) command = ";".join(command)