wrap DFS and CRDS in Pipeline

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"