diff --git a/csst_common/pipeline.py b/csst_common/pipeline.py index 0b5b5e1fd9f6d6f7aa6be28de3372c2a01e7b33d..43e8abdc1c90cdd8236274f13e47f085641fbbb6 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