Commit 38a353b4 authored by BO ZHANG's avatar BO ZHANG 🏀
Browse files

debug _id_data

parent 0581c0be

csst_dag/dag/_dispatcher.py

+2 −2
Original line number Diff line number Diff line
@@ -506,7 +506,7 @@ class Dispatcher: 
                ],

                join_type="inner",

            )

            print(this_data_obsid_file.colnames)

            # print(this_data_obsid_file.colnames)

            this_data_obsid_plan = table.join(

                this_data_obsid,

                relevant_plan,
@@ -562,7 +562,7 @@ class Dispatcher: 
                    relevant_data_id_list=(

                        []

                        if len(this_data_obsid_file) == 0

                        else list(this_data_obsid_file["_id_data"])

                        else list(this_data_obsid_file["_id"])

                    ),

                    n_file_expected=this_data_obsid_plan["n_file"].sum(),

                    n_file_found=len(this_data_obsid_file),