Loading csst_dag/dag/_dispatcher.py +2 −2 Original line number Diff line number Diff line Loading @@ -511,7 +511,7 @@ class Dispatcher: this_data_obsid_file["detector"] ) n_file_expected = this_data_obsid_plan["n_frame"].sum() n_file_expected = int(this_data_obsid_plan["n_frame"].sum()) n_file_found = len(this_data_obsid_file) # set n_file_expected and n_file_found this_task["n_file_expected"] = n_file_expected Loading Loading @@ -612,7 +612,7 @@ class Dispatcher: this_obsgroup_obsid_file["detector"] ) n_file_expected = this_obsgroup_plan["n_frame"].sum() n_file_expected = int(this_obsgroup_plan["n_frame"].sum()) n_file_found = len(this_obsgroup_file) # set n_file_expected and n_file_found this_task["n_file_expected"] = n_file_expected Loading Loading
csst_dag/dag/_dispatcher.py +2 −2 Original line number Diff line number Diff line Loading @@ -511,7 +511,7 @@ class Dispatcher: this_data_obsid_file["detector"] ) n_file_expected = this_data_obsid_plan["n_frame"].sum() n_file_expected = int(this_data_obsid_plan["n_frame"].sum()) n_file_found = len(this_data_obsid_file) # set n_file_expected and n_file_found this_task["n_file_expected"] = n_file_expected Loading Loading @@ -612,7 +612,7 @@ class Dispatcher: this_obsgroup_obsid_file["detector"] ) n_file_expected = this_obsgroup_plan["n_frame"].sum() n_file_expected = int(this_obsgroup_plan["n_frame"].sum()) n_file_found = len(this_obsgroup_file) # set n_file_expected and n_file_found this_task["n_file_expected"] = n_file_expected Loading