Commit 5cd9e1e4 authored by BO ZHANG's avatar BO ZHANG 🏀
Browse files

tweaks

parent 3f5bef29
...@@ -62,9 +62,9 @@ if args.obs_type: ...@@ -62,9 +62,9 @@ if args.obs_type:
DAG_MAP = {args.obs_type: DAG_MAP[args.obs_type]} DAG_MAP = {args.obs_type: DAG_MAP[args.obs_type]}
for obs_type, dags in DAG_MAP.items(): for obs_type, dags in DAG_MAP.items():
print(f"* Processing `{obs_type}`") print(f"- Processing `{obs_type}`")
for this_dag in dags: for this_dag in dags:
print(f" - Scheduling `{this_dag}`") print(f" * `{this_dag}`: ", end="")
dag = CsstDAGs().get(this_dag) dag = CsstDAGs().get(this_dag)
dag_group_run, dag_run_list = dag.schedule( dag_group_run, dag_run_list = dag.schedule(
batch_id=args.batch_id, batch_id=args.batch_id,
......
...@@ -179,9 +179,9 @@ class GeneralL1DAG(BaseDAG): ...@@ -179,9 +179,9 @@ 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 -> {res_push}")
assert res_push.success, res_push.message assert res_push.success, res_push.message
else: else:
# no push # no push
print(f" * {len(dag_run_list)} DAG runs.") print(f"{len(dag_run_list)} DAG runs.")
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