Commit 9372848e authored by BO ZHANG's avatar BO ZHANG 🏀
Browse files

tweaks

parent 77606137
...@@ -110,8 +110,9 @@ class BaseDAG: ...@@ -110,8 +110,9 @@ class BaseDAG:
dag_run_list = [] dag_run_list = []
for this_task in task_list: for this_task in task_list:
dag_run = self.gen_dag_run( dag_run = self.gen_dag_run(
dag_group_run=dag_group_run, **dag_group_run,
dag_run_kwargs=this_task["task"], **this_task["task"],
**kwargs,
) )
dag_run_list.append(dag_run) dag_run_list.append(dag_run)
......
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