diff --git a/csst_common/data_manager.py b/csst_common/data_manager.py index e02cd8cfa0455cd1114c2309d6e82d6674661cd3..2b8c6a5c0686486c744ad59e002dcf3598712913 100644 --- a/csst_common/data_manager.py +++ b/csst_common/data_manager.py @@ -201,9 +201,6 @@ class CsstMsDataManager: self.n_jobs = 18 - # DFS APIs - # self.l1api = Level1DataApi() - # aXe self.set_env() @@ -220,6 +217,7 @@ class CsstMsDataManager: self.logger_mod = get_logger(name="CSST L1 Module Logger", filename=os.path.join(dir_l1, log_mod)) self.logger_mod.info("logger_mod initialized") + # DFS APIs self.dfs_L0DataApi = Level0DataApi() self.dfs_L1DataApi = Level1DataApi() self.dfs_L0PrcApi = Level0PrcApi() # level0到level1的处理过程记录 @@ -572,6 +570,7 @@ class CsstMsDataManager: dfs_mode=True, dfs_node="pml"): """ Initialize CsstMsDataManager from DFS. """ records = Level0DataApi().find(obs_id=obs_id) # query DFS + print(f"{records['totalCount']} records obtained!") tbl = Table([_.__dict__ for _ in records["data"]]) tbl.sort(["detector_no", "obs_type"])