teaks

    this_dag_run_list = [this_task["dag_run"] for this_task in this_task_list if this_task["dag_run"] is not None]

    this_data_id_list = [this_task["relevant_data_id_list"] for this_task in this_task_list if this_task["dag_run"] is not None]

    print(f"- [{dag}] : {len(this_dag_run_list)} dag_runs")

    dag_run_list.extend(this_dag_run_list)

    data_id_list.extend(this_data_id_list)

    n_dag_run_all += len(this_task_list)

    n_dag_run_success += len(this_dag_run_list)

    print(f"- [{dag}] : {len(this_dag_run_list)}/{len(this_task_list)} dag_runs")

# print dag_group_run and dag_run_list

print("\n")

print(">>> dag_group_run:")

print(f"\t- {dag_group_run}")

print(f">>> dag_run_list[{n_dag_run_success}/[{n_dag_run_all}]]:")

print(f">>> dag_run_list[{n_dag_run_success}/{n_dag_run_all}]:")

if len(dag_run_list) > 0:

    for dag_run in dag_run_list:

        print(f"\t- {dag_run}")

{

    "dag_group": "csst_dag.cli.msc_l1",

    "dag_group": "csst-msc-l1",

    "dag_group_run": "195244ff176f923aec9a9328c75ecaeb4a8c4345",

    "dag": "csst-msc-l1-mbi",

    "dag": "csst-msc-l1-sls",

    "dag_run": "c89d7e7a022e6f0cdf1daff921c29dbce0ac7c01",

    "batch_id": "inttest",

    "priority": 1,