diff --git a/csst_common/pipeline.py b/csst_common/pipeline.py
index 35f9266a3c00189832dd6f12ca4e6d47ae1e7cd2..437d3dbe18c6bdad0c0cd62d69f0f72b25bcad8c 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"