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

print number of records

parent 64b61d82

csst_dag/dag/_dispatcher.py

+3 −0
Original line number Diff line number Diff line
@@ -161,6 +161,7 @@ class Dispatcher: 
        # query

        qr = plan.find(**override_common_keys(PLAN_PARAMS, kwargs))

        assert qr.success, qr

        print(f"Found {len(qr.data)} plan records.")

        # plan basis / obsid basis

        try:

            for _ in qr.data:
@@ -189,6 +190,7 @@ class Dispatcher: 
        # query

        qr = level0.find(**override_common_keys(LEVEL0_PARAMS, kwargs))

        assert qr.success, qr

        print(f"Found {len(qr.data)} level0 records.")

        # data basis

        data_basis = extract_basis_table(

            qr.data,
@@ -204,6 +206,7 @@ class Dispatcher: 
        # query

        qr = level1.find(**override_common_keys(LEVEL1_PARAMS, kwargs))

        assert qr.success, qr

        print(f"Found {len(qr.data)} level1 records.")

        # data basis

        data_basis = extract_basis_table(

            qr.data,