File tree Expand file tree Collapse file tree 1 file changed +1
-2
lines changed
Expand file tree Collapse file tree 1 file changed +1
-2
lines changed Original file line number Diff line number Diff line change 1010import json
1111import threading
1212import traceback
13- import uuid
1413from concurrent .futures import ThreadPoolExecutor
1514from functools import reduce
1615from typing import List , Dict
2524from rest_framework .exceptions import ErrorDetail , ValidationError
2625
2726from application .flow import tools
28- from application .flow .common import Answer
2927from application .flow .i_step_node import INode , WorkFlowPostHandler , NodeResult
3028from application .flow .step_node import get_node
3129from common .exception .app_exception import AppApiException
@@ -312,6 +310,7 @@ def get_node_params(n):
312310 node = self .get_node_cls_by_id (node_id , node_details .get ('up_node_id_list' ))
313311 node .valid_args (node .node_params , node .workflow_params )
314312 node .save_context (node_details , self )
313+ node .node_chunk .end ()
315314 self .node_context .append (node )
316315
317316 def run (self ):
You can’t perform that action at this time.
0 commit comments