Commit 8a008f7d authored by BO ZHANG's avatar BO ZHANG 🏀
Browse files

tweaks

parent 30e30945
...@@ -158,9 +158,9 @@ class GeneralL1DAG(BaseDAG): ...@@ -158,9 +158,9 @@ class GeneralL1DAG(BaseDAG):
obs_id=this_rec["obs_id"], obs_id=this_rec["obs_id"],
**additional_keys, **additional_keys,
) )
if demo: dag_run_list.append(this_dag_run)
print(json.dumps(this_dag_run, indent=4), end="")
# update level0 prc_status # update level0 prc_status
if not demo:
this_update = level0.update_prc_status( this_update = level0.update_prc_status(
level0_id=this_rec["level0_id"], level0_id=this_rec["level0_id"],
dag_run_id=this_dag_run["dag_run_id"], dag_run_id=this_dag_run["dag_run_id"],
...@@ -168,7 +168,6 @@ class GeneralL1DAG(BaseDAG): ...@@ -168,7 +168,6 @@ class GeneralL1DAG(BaseDAG):
dataset=dataset, dataset=dataset,
) )
assert this_update.success, this_update.message assert this_update.success, this_update.message
dag_run_list.append(this_dag_run)
if not demo: if not demo:
# push and update # push and update
......
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