diff --git a/csst_common/data_manager.py b/csst_common/data_manager.py
index 0263faa6f86adcb6f8f1710911bd33c659a96d14..3e4e7d4ab3821c663f3e7be5a1e1834e8d50cd6d 100644
--- a/csst_common/data_manager.py
+++ b/csst_common/data_manager.py
@@ -573,7 +573,7 @@ class CsstMsDataManager:
     def from_dfs(obs_id="100000100", datatype="mbi", dir_l0="/L1Pipeline/L0", dir_l1="/L1Pipeline/L1",
                  dfs_mode=True, dfs_node="pml"):
         """ Initialize CsstMsDataManager from DFS. """
-        records = Level0DataApi().find(obs_id=obs_id)  # query DFS
+        records = CsstMsDataManager(dfs_node=dfs_node).dfs_L0DataApi.find(obs_id=obs_id)
         print(f"{records['totalCount']} records obtained!")
         tbl = Table([_.__dict__ for _ in records["data"]])
         tbl.sort(["detector_no", "obs_type"])