Commit 8b383347 authored by BO ZHANG's avatar BO ZHANG 🏀
Browse files

return recs in dm.link_L0Data

parent ff554c98
...@@ -820,7 +820,7 @@ class CsstMsDataManager: ...@@ -820,7 +820,7 @@ class CsstMsDataManager:
pass pass
@staticmethod @staticmethod
def link_data(obs_id="100000100", dfs_root="/dfsroot", dir_l0="/L1Pipeline/L0"): def link_L0Data(obs_id="100000100", dfs_root="/dfsroot", dir_l0="/L1Pipeline/L0"):
# query for L0 data # query for L0 data
print(f"Query obs_id={obs_id} ...", end="") print(f"Query obs_id={obs_id} ...", end="")
recs = Level0DataApi().find(obs_id=obs_id) recs = Level0DataApi().find(obs_id=obs_id)
...@@ -835,6 +835,8 @@ class CsstMsDataManager: ...@@ -835,6 +835,8 @@ class CsstMsDataManager:
src=os.path.join(dfs_root, rec.file_path), src=os.path.join(dfs_root, rec.file_path),
dst=os.path.join(dir_l0, os.path.basename(rec.file_path)), dst=os.path.join(dir_l0, os.path.basename(rec.file_path)),
) )
# return records
return recs
@staticmethod @staticmethod
def from_dfs( def from_dfs(
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment