(self, flow: Workflow,
params,
work_flow_post_handler: WorkFlowPostHandler,
parentWorkflowManage,
loop_params,
get_loop_context,
base_to_response: BaseToResponse = SystemToResponse(),
start_node_id=None,
start_node_data=None, chat_record=None, child_node=None, is_the_task_interrupted=lambda: False)
| 85 | class LoopWorkflowManage(WorkflowManage): |
| 86 | |
| 87 | def __init__(self, flow: Workflow, |
| 88 | params, |
| 89 | work_flow_post_handler: WorkFlowPostHandler, |
| 90 | parentWorkflowManage, |
| 91 | loop_params, |
| 92 | get_loop_context, |
| 93 | base_to_response: BaseToResponse = SystemToResponse(), |
| 94 | start_node_id=None, |
| 95 | start_node_data=None, chat_record=None, child_node=None, is_the_task_interrupted=lambda: False): |
| 96 | self.parentWorkflowManage = parentWorkflowManage |
| 97 | self.loop_params = loop_params |
| 98 | self.get_loop_context = get_loop_context |
| 99 | self.loop_field_list = [] |
| 100 | super().__init__(flow, params, work_flow_post_handler, base_to_response, None, None, None, |
| 101 | None, |
| 102 | None, None, start_node_id, start_node_data, chat_record, child_node, is_the_task_interrupted) |
| 103 | |
| 104 | def get_node_cls_by_id(self, node_id, up_node_id_list=None, |
| 105 | get_node_params=lambda node: node.properties.get('node_data')): |
nothing calls this directly
no test coverage detected