Commit 5cb66233 authored by BO ZHANG's avatar BO ZHANG 🏀
Browse files

return relevant_data_id_list in dispatchers

parent f870e11e
...@@ -285,6 +285,7 @@ class Dispatcher: ...@@ -285,6 +285,7 @@ class Dispatcher:
relevant_data=data_basis[i_data_basis : i_data_basis + 1], relevant_data=data_basis[i_data_basis : i_data_basis + 1],
n_relevant_plan=len(this_relevant_plan), n_relevant_plan=len(this_relevant_plan),
n_relevant_data=1, n_relevant_data=1,
relevant_data_id_list=[data_basis[i_data_basis]["_id"]],
) )
) )
...@@ -403,6 +404,11 @@ class Dispatcher: ...@@ -403,6 +404,11 @@ class Dispatcher:
relevant_data=this_data_detector_files, relevant_data=this_data_detector_files,
n_relevant_plan=len(this_data_detector_plan), n_relevant_plan=len(this_data_detector_plan),
n_relevant_data=len(this_data_detector_files), n_relevant_data=len(this_data_detector_files),
relevant_data_id_list=(
[]
if len(this_data_detector_files) == 0
else list(this_data_detector_files["_id"])
),
) )
) )
return task_list return task_list
...@@ -514,6 +520,11 @@ class Dispatcher: ...@@ -514,6 +520,11 @@ class Dispatcher:
relevant_data=this_data_obsid_file, relevant_data=this_data_obsid_file,
n_relevant_plan=len(this_data_obsid_plan), n_relevant_plan=len(this_data_obsid_plan),
n_relevant_data=len(this_data_obsid_file), n_relevant_data=len(this_data_obsid_file),
relevant_data_id_list=(
[]
if len(this_data_obsid_file) == 0
else list(this_data_obsid_file["_id"])
),
) )
) )
...@@ -607,6 +618,11 @@ class Dispatcher: ...@@ -607,6 +618,11 @@ class Dispatcher:
relevant_data=this_obsgroup_file, relevant_data=this_obsgroup_file,
n_relevant_plan=len(this_obsgroup_plan), n_relevant_plan=len(this_obsgroup_plan),
n_relevant_data=this_obsgroup_file, n_relevant_data=this_obsgroup_file,
relevant_data_id_list=(
[]
if len(this_obsgroup_file) == 0
else list(this_obsgroup_file["_id"])
),
) )
) )
return task_list return task_list
......
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