From e9dc9d641a9dde49e218a0e4f57c7044a3e5452d Mon Sep 17 00:00:00 2001
From: Fabrice Le Goff <fabrice.le.goff@cern.ch>
Date: Tue, 11 Jul 2023 11:46:39 +0200
Subject: [PATCH] adding logs to debug ongoing error
---
Script/cs/StorageBackends/eosstorage.py | 10 ++++++----
1 file changed, 6 insertions(+), 4 deletions(-)
diff --git a/Script/cs/StorageBackends/eosstorage.py b/Script/cs/StorageBackends/eosstorage.py
index 33f4b17..9574130 100644
--- a/Script/cs/StorageBackends/eosstorage.py
+++ b/Script/cs/StorageBackends/eosstorage.py
@@ -72,13 +72,14 @@ def sizechecksum(filename, stager, logger=None):
def remove(dstfile, stager, logger=None):
- xrdfs = subprocess.Popen(['xrdfs',stager,'rm',dstfile], stdout=subprocess.PIPE,
- stderr=subprocess.STDOUT)
+ cmd = ['xrdfs', stager, 'rm', dstfile]
+ xrdfs = subprocess.Popen(cmd, stdout=subprocess.PIPE,
+ stderr=subprocess.STDOUT)
ret = xrdfs.wait()
if ret != 0 and logger is not None:
- logger.warning('error removing %s, output: %s', dstfile,
- xrdfs.stdout.read().decode())
+ logger.warning('error removing %s, cmd: %s, output: %s', dstfile,
+ str(cmd), xrdfs.stdout.read().decode())
return ret
@@ -101,6 +102,7 @@ def backgroundcopy(srcfile, dstfile, stager, logger=None):
if 'XRD_STREAMTIMEOUT' in config_dict:
modified_env['XRD_STREAMTIMEOUT'] = str(config_dict['XRD_STREAMTIMEOUT'])
+ logger.debug("starting background copy, cmd: %s", str(cmd))
xrdcp = subprocess.Popen(cmd, stdout=subprocess.PIPE,
stderr=subprocess.STDOUT, env=modified_env)
--
GitLab