zhuchaowe/maxkb
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: After the workflow form collection node is recalled, the subsequent nodes will not execute (#2195)

Browse Source
This commit is contained in:
shaohuzhang1 2025-02-10 11:36:49 +08:00 committed by GitHub
parent 041cf09011
commit be27e15885
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
apps/application/flow/workflow_manage.py
View File

@ -10,7 +10,6 @@ import concurrent
import json import json
import threading import threading
import traceback import traceback
import uuid
from concurrent.futures import ThreadPoolExecutor from concurrent.futures import ThreadPoolExecutor
from functools import reduce from functools import reduce
from typing import List, Dict from typing import List, Dict
@ -25,7 +24,6 @@ from rest_framework import status
from rest_framework.exceptions import ErrorDetail, ValidationError from rest_framework.exceptions import ErrorDetail, ValidationError
from application.flow import tools from application.flow import tools
from application.flow.common import Answer
from application.flow.i_step_node import INode, WorkFlowPostHandler, NodeResult from application.flow.i_step_node import INode, WorkFlowPostHandler, NodeResult
from application.flow.step_node import get_node from application.flow.step_node import get_node
from common.exception.app_exception import AppApiException from common.exception.app_exception import AppApiException
@ -312,6 +310,7 @@ class WorkflowManage:
node = self.get_node_cls_by_id(node_id, node_details.get('up_node_id_list')) node = self.get_node_cls_by_id(node_id, node_details.get('up_node_id_list'))
node.valid_args(node.node_params, node.workflow_params) node.valid_args(node.node_params, node.workflow_params)
node.save_context(node_details, self) node.save_context(node_details, self)
node.node_chunk.end()
self.node_context.append(node) self.node_context.append(node)
def run(self): def run(self):