Commit a4f2850b authored by BO ZHANG's avatar BO ZHANG 🏀
Browse files

add n_file_expected and n_file_found

parent a5c06a4b
...@@ -284,6 +284,8 @@ class Dispatcher: ...@@ -284,6 +284,8 @@ class Dispatcher:
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"]], relevant_data_id_list=[data_basis[i_data_basis]["_id"]],
n_file_expected=1,
n_file_found=1,
) )
) )
...@@ -403,6 +405,8 @@ class Dispatcher: ...@@ -403,6 +405,8 @@ class Dispatcher:
if len(this_data_detector_files) == 0 if len(this_data_detector_files) == 0
else list(this_data_detector_files["_id_data"]) else list(this_data_detector_files["_id_data"])
), ),
n_file_expected=this_data_detector_plan["n_frame"].sum(),
n_file_found=len(this_data_detector_files),
) )
) )
return task_list return task_list
...@@ -515,6 +519,8 @@ class Dispatcher: ...@@ -515,6 +519,8 @@ class Dispatcher:
if len(this_data_obsid_file) == 0 if len(this_data_obsid_file) == 0
else list(this_data_obsid_file["_id_data"]) else list(this_data_obsid_file["_id_data"])
), ),
n_file_expected=this_data_obsid_plan["n_frame"].sum(),
n_file_found=len(this_data_obsid_file),
) )
) )
...@@ -609,6 +615,8 @@ class Dispatcher: ...@@ -609,6 +615,8 @@ class Dispatcher:
if len(this_obsgroup_file) == 0 if len(this_obsgroup_file) == 0
else list(this_obsgroup_file["_id_data"]) else list(this_obsgroup_file["_id_data"])
), ),
n_file_expected=this_obsgroup_plan["n_frame"].sum(),
n_file_found=len(this_obsgroup_file),
) )
) )
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