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

tweaks

parent 58b7abfe
......@@ -124,12 +124,6 @@ class GeneralL1DAG(BaseDAG):
batch_id=batch_id,
priority=priority,
)
if demo:
# print(json.dumps(dag_group_run, indent=4))
# try single-lined json verbose
print(
" - " + json.dumps(dag_group_run, indent=None, separators=(",", ":"))
)
# find level0 data records
recs = level0.find(
......@@ -183,5 +177,8 @@ class GeneralL1DAG(BaseDAG):
assert res_push.success, res_push.message
else:
# no push
print(f"{len(dag_run_list)} DAG runs.")
print(
f"{len(dag_run_list)} DAG runs -> {json.dumps(dag_group_run, indent=None, separators=(',', ':'))}"
)
# TODO: `dag_group_run` and `dag_run_list` should be dumped to a text file in the future
return dag_group_run, dag_run_list
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