Commit 30e30945 authored by BO ZHANG's avatar BO ZHANG 🏀
Browse files

tweaks

parent aa530dca
...@@ -173,12 +173,17 @@ class GeneralL1DAG(BaseDAG): ...@@ -173,12 +173,17 @@ class GeneralL1DAG(BaseDAG):
if not demo: if not demo:
# push and update # push and update
res_push = self.push_dag_group_run(dag_group_run, dag_run_list) res_push = self.push_dag_group_run(dag_group_run, dag_run_list)
print(f"{len(dag_run_list)} DAG runs -> {res_push}") print(
f"{len(dag_run_list)} DAG runs -> "
f"{json.dumps(dag_group_run, indent=None, separators=(',', ':'))} -> "
f"{res_push}"
)
assert res_push.success, res_push.message assert res_push.success, res_push.message
else: else:
# no push # no push
print( print(
f"{len(dag_run_list)} DAG runs -> {json.dumps(dag_group_run, indent=None, separators=(',', ':'))}" f"{len(dag_run_list)} DAG runs -> "
f"{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 # 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 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