This commit is contained in:
yumoqing 2026-03-13 14:51:25 +08:00
parent ead330298b
commit 7c43ba8880

View File

@ -3,7 +3,7 @@ from functools import partial
from appPublic.jsonConfig import getConfig
from ahserver.serverenv import ServerEnv
from ahserver.configuredServer import add_cleanupctx
from .dagflow import FlowEngine
from .dagflow import FlowEngine, add_new_workflow
async def dagbacktask(engines, app):
tasks = []
@ -26,4 +26,5 @@ def load_dagflow():
add_cleanupctx(f)
env = ServerEnv()
env.flow_engines = flow_engines
env.add_new_workflow = add_new_workflow