yumoqing/dagflow
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2026-03-17 17:48:10 +08:00
parent fe7109d0fd
commit ab16535041
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
dagflow/dagflow.py
View File

@ -337,7 +337,7 @@ where backid=${backid}$
debug(f'{ne.node_id}处理完成') debug(f'{ne.node_id}处理完成')
def build_node_input_ctx(self, inst, ne): def build_node_input_ctx(self, ne):
ctx = json.loads(ne.ctx) ctx = json.loads(ne.ctx)
if ne.ctx_ext: if ne.ctx_ext:
ctx_ext = json.loads(ns.ctx_ext) ctx_ext = json.loads(ns.ctx_ext)
@ -349,7 +349,7 @@ where backid=${backid}$
if subflow_id is None: if subflow_id is None:
debug(f'{node=} 没有subflow_id属性') debug(f'{node=} 没有subflow_id属性')
return return
sub_ctx = self.build_node_input_ctx(inst, ne) sub_ctx = self.build_node_input_ctx(ne)
ne.subinst_id = await self.create_instance( ne.subinst_id = await self.create_instance(
ne.org_id, ne.org_id,
subflow_id, ctx=sub_ctx) subflow_id, ctx=sub_ctx)
@ -363,7 +363,7 @@ where backid=${backid}$
if not users: if not users:
debug(f'{ne.org_id=} 没有用户') debug(f'{ne.org_id=} 没有用户')
return return
sub_ctx = self.build_node_input_ctx(inst, ne) sub_ctx = self.build_node_input_ctx(ne)
try: try:
f = partial(self.task_success_callback, ne.id) f = partial(self.task_success_callback, ne.id)
ef = partial(self.task_error_callback, ne.id) ef = partial(self.task_error_callback, ne.id)