From d08f20edfb38442ab7dd7267537d07099f109d79 Mon Sep 17 00:00:00 2001 From: BO ZHANG Date: Tue, 20 Jan 2026 11:13:50 +0800 Subject: [PATCH] abspath in OSS case --- csst_common/pipeline.py | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/csst_common/pipeline.py b/csst_common/pipeline.py index 0b5b5e1..43e8abd 100644 --- a/csst_common/pipeline.py +++ b/csst_common/pipeline.py @@ -248,7 +248,11 @@ class Pipeline: """Convert `file_path` to absolute path for DFS.""" dfs_recs_abs = copy.deepcopy(dfs_rec_list) for rec in dfs_recs_abs: - rec["file_path"] = os.path.join(self.dfs_root, rec["file_path"]) + rec["file_path"] = ( + os.path.join(self.dfs_root, rec["file_path"]) + if rec["file_path"].__contains__(":") + else rec["file_path"] + ) return dfs_recs_abs def convert_to_abspath_for_ccds_refs(self, ccds_refs: dict) -> dict: @@ -257,7 +261,11 @@ class Pipeline: print(ccds_refs_abs) for ref_name, ref_path in ccds_refs_abs["refs"].items(): print(ref_name, ref_path) - ccds_refs_abs["refs"][ref_name] = os.path.join(self.ccds_root, ref_path) + ccds_refs_abs["refs"][ref_name] = ( + os.path.join(self.ccds_root, ref_path) + if ref_path["file_path"].__contains__(":") + else ref_path + ) print(ccds_refs_abs) return ccds_refs_abs -- GitLab