Loading app/ADL/api/fs.py +4 −4 Original line number Diff line number Diff line Loading @@ -195,8 +195,7 @@ class GUCFileSystem(AsyncFileSystem): if config.debug: cmd_args.append('-dbg') cmd_args += args cmd_args += source cmd_args += destination.as_posix() cmd_args += (source, destination.as_posix()) log.debug('Executing %s %s', self.guc_bin, cmd_args) p = await create_subprocess_exec(self.guc_bin, *cmd_args, stdout=PIPE, stderr=STDOUT) Loading @@ -209,7 +208,8 @@ class GUCFileSystem(AsyncFileSystem): log.error(stderr) rc = p.returncode if not rc == 0: if (not rc == 0): if destination.exists(): destination.unlink() raise HPSSError(f'globus_url_copy returned {rc}') Loading Loading
app/ADL/api/fs.py +4 −4 Original line number Diff line number Diff line Loading @@ -195,8 +195,7 @@ class GUCFileSystem(AsyncFileSystem): if config.debug: cmd_args.append('-dbg') cmd_args += args cmd_args += source cmd_args += destination.as_posix() cmd_args += (source, destination.as_posix()) log.debug('Executing %s %s', self.guc_bin, cmd_args) p = await create_subprocess_exec(self.guc_bin, *cmd_args, stdout=PIPE, stderr=STDOUT) Loading @@ -209,7 +208,8 @@ class GUCFileSystem(AsyncFileSystem): log.error(stderr) rc = p.returncode if not rc == 0: if (not rc == 0): if destination.exists(): destination.unlink() raise HPSSError(f'globus_url_copy returned {rc}') Loading