diff --git a/dagflow/init.py b/dagflow/init.py index 582bbc8..7197557 100644 --- a/dagflow/init.py +++ b/dagflow/init.py @@ -7,7 +7,7 @@ from .dagflow import ( FlowEngine, get_org_flow_definition add_new_workflow -} +) async def dagbacktask(engines, app): tasks = []