From 0e355e6d6d7709a1d60553ccb1f37ad9cd698158 Mon Sep 17 00:00:00 2001 From: BO ZHANG Date: Tue, 11 Jul 2023 17:57:50 +0800 Subject: [PATCH] wrap DFS and CRDS in Pipeline --- csst_common/pipeline.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/csst_common/pipeline.py b/csst_common/pipeline.py index 35f9266..437d3db 100644 --- a/csst_common/pipeline.py +++ b/csst_common/pipeline.py @@ -4,6 +4,8 @@ import subprocess from astropy import time +from .crds import CRDS +from .dfs import DFS from .logger import get_logger @@ -49,6 +51,9 @@ class Pipeline: self.time_stamp = TimeStamp(os.path.join(self.dir_out, "time_stamp.txt")) self.exit_code = ExitCode(os.path.join(self.dir_out, "exit_code")) + self.dfs = DFS(n_try=5) + self.crds = CRDS() + def set_test_env(self): os.environ["CSST_DFS_API_MODE"] = "cluster" os.environ["CSST_DFS_GATEWAY"] = "172.24.27.2:30880" -- GitLab