15308555518/ MaxKB
1
0
Fork 0
mirror of https://github.com/1Panel-dev/MaxKB.git synced 2025-12-26 01:33:05 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

fix: Continue and break to fill in conversation details (#4094)

This commit is contained in:
shaohuzhang1 2025-09-23 19:47:07 +08:00 committed by GitHub
parent d26b61f18b
commit e46cb54e45
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
apps/application/flow/step_node/loop_break_node/impl/base_loop_break_node.py
View File

@ -28,6 +28,7 @@ class BaseLoopBreakNode(ILoopBreakNode):
is_break = all(r) if condition == 'and' else any(r)
if is_break:
self.node_params['is_result'] = True
self.context['is_break'] = is_break
return NodeResult({'is_break': is_break}, {},
_write_context=_write_context,
_is_interrupt=lambda n, v, w: is_break)
@ -50,7 +51,7 @@ class BaseLoopBreakNode(ILoopBreakNode):
return {
'name': self.node.properties.get('stepName'),
"index": index,
"question": self.context.get('question'),
'is_break': self.context.get('is_break'),
'run_time': self.context.get('run_time'),
'type': self.node.type,
'status': self.status,

3
apps/application/flow/step_node/loop_continue_node/impl/base_loop_continue_node.py
View File

@ -18,6 +18,7 @@ class BaseLoopContinueNode(ILoopContinueNode):
condition_list = [self.assertion(row.get('field'), row.get('compare'), row.get('value')) for row in
condition_list]
is_continue = all(condition_list) if condition == 'and' else any(condition_list)
self.context['is_continue'] = is_continue
if is_continue:
return NodeResult({'is_continue': is_continue, 'branch_id': 'continue'}, {})
return NodeResult({'is_continue': is_continue}, {})
@ -40,7 +41,7 @@ class BaseLoopContinueNode(ILoopContinueNode):
return {
'name': self.node.properties.get('stepName'),
"index": index,
"question": self.context.get('question'),
"is_continue": self.context.get('is_continue'),
'run_time': self.context.get('run_time'),
'type': self.node.type,
'status': self.status,