Commit 35796d08 authored by BO ZHANG's avatar BO ZHANG 🏀
Browse files

add csst_hstdm_l1.py

parent b573d99a
...@@ -81,10 +81,11 @@ dag_group_run = BaseDAG.gen_dag_group_run( ...@@ -81,10 +81,11 @@ dag_group_run = BaseDAG.gen_dag_group_run(
print("\n"*2) print("\n"*2)
print(">>> Matching DAGs ...") print(">>> Matching DAGs ...")
dag_run_list = [] dag_run_list = []
data_id_set = set()
for dag in [ for dag in [
"csst-hstdm-l1", "csst-hstdm-l1",
]: ]:
this_dag_run_list = CSST_DAGS[dag].schedule( this_dag_run_list, this_data_id_set = CSST_DAGS[dag].schedule(
dag_group_run=dag_group_run, dag_group_run=dag_group_run,
plan_basis=plan_basis, plan_basis=plan_basis,
data_basis=data_basis, data_basis=data_basis,
...@@ -92,6 +93,7 @@ for dag in [ ...@@ -92,6 +93,7 @@ for dag in [
) )
print(f"- [{dag}] : {len(this_dag_run_list)} dag_runs") print(f"- [{dag}] : {len(this_dag_run_list)} dag_runs")
dag_run_list.extend(this_dag_run_list) dag_run_list.extend(this_dag_run_list)
data_id_set.union(this_data_id_set)
# print dag_group_run and dag_run_list # print dag_group_run and dag_run_list
print("\n") print("\n")
......
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