Commit 89f2ad14 authored by BO ZHANG's avatar BO ZHANG 🏀
Browse files

tweaks

parent 33a96aa1
......@@ -99,18 +99,19 @@ for dag in [
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]
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")
this_n_dag_run_all = len(this_task_list)
this_n_dag_run_success = len(this_dag_run_list)
n_dag_run_all += this_n_dag_run_all
n_dag_run_success += this_n_dag_run_success
print(f"- `{dag}` : [{this_n_dag_run_all} / {this_n_dag_run_success}] dag_runs")
# print dag_group_run and dag_run_list
print("\n")
print(">>> dag_group_run:")
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}")
......
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