From df127cd24713401c151f28a0e914ca1ad25201a2 Mon Sep 17 00:00:00 2001 From: BO ZHANG Date: Mon, 19 Jan 2026 16:51:46 +0800 Subject: [PATCH 1/2] print arguments --- csst_common/pipeline.py | 1 + 1 file changed, 1 insertion(+) diff --git a/csst_common/pipeline.py b/csst_common/pipeline.py index 6d0a327..e756519 100644 --- a/csst_common/pipeline.py +++ b/csst_common/pipeline.py @@ -209,6 +209,7 @@ class Pipeline: @staticmethod def dump_oss_file(rpath: str, lpath: str) -> str: """Copy OSS file `file_src` to `file_dist`.""" + print(f"rpath={rpath}, lpath={lpath}") s3_fs.get(rpath, lpath) assert os.path.exists(lpath), f"Failed to dump OSS file {rpath} to {lpath}!" return lpath -- GitLab From 84189b1b65b808aabd52713756b9c9ca94b0c6e3 Mon Sep 17 00:00:00 2001 From: BO ZHANG Date: Mon, 19 Jan 2026 17:13:18 +0800 Subject: [PATCH 2/2] write log while dumping file --- csst_common/pipeline.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/csst_common/pipeline.py b/csst_common/pipeline.py index e756519..d1dd73e 100644 --- a/csst_common/pipeline.py +++ b/csst_common/pipeline.py @@ -233,14 +233,14 @@ class Pipeline: """Create new file in output directory.""" return os.path.join(self.dir_output, file_name) - @staticmethod - def dump_file(remote_file_path: str, local_file_path: str = None) -> str: + def dump_file(self, remote_file_path: str, local_file_path: str = None) -> str: """Copy file `remote_file_path` to `local_file_path`.""" is_oss = remote_file_path.__contains__(":") + self.logger.info(f"Dumping file: {remote_file_path} -> {local_file_path}") if is_oss: - local_file_path = Pipeline.dump_oss_file(remote_file_path, local_file_path) + local_file_path = self.dump_oss_file(remote_file_path, local_file_path) else: - local_file_path = Pipeline.copy_nas_file(remote_file_path, local_file_path) + local_file_path = self.copy_nas_file(remote_file_path, local_file_path) return local_file_path # abspath -- GitLab