(**kwargs)
| 1045 | took_execute = ToolExecute(tool_id, tool_record_id, workspace_id, source_type, source_id, False) |
| 1046 | |
| 1047 | def inner(**kwargs): |
| 1048 | from application.flow.tool_workflow_manage import ToolWorkflowManage |
| 1049 | |
| 1050 | work_flow_manage = ToolWorkflowManage( |
| 1051 | Workflow.new_instance(qv.work_flow, WorkflowMode.TOOL), |
| 1052 | { |
| 1053 | "chat_record_id": tool_record_id, |
| 1054 | "tool_id": tool_id, |
| 1055 | "stream": True, |
| 1056 | "workspace_id": workspace_id, |
| 1057 | **kwargs, |
| 1058 | }, |
| 1059 | ToolWorkflowPostHandler(took_execute, tool_id), |
| 1060 | is_the_task_interrupted=lambda: False, |
| 1061 | child_node=None, |
| 1062 | start_node_id=None, |
| 1063 | start_node_data=None, |
| 1064 | chat_record=None, |
| 1065 | ) |
| 1066 | res = work_flow_manage.run() |
| 1067 | for r in res: |
| 1068 | pass |
| 1069 | return work_flow_manage.out_context |
| 1070 | |
| 1071 | return inner |
| 1072 |
no test coverage detected