|
| 1 | +# coding=utf-8 |
| 2 | +""" |
| 3 | + @project: MaxKB |
| 4 | + @Author：虎虎 |
| 5 | + @file： workflow.py |
| 6 | + @date：2025/5/9 10:58 |
| 7 | + @desc: |
| 8 | +""" |
| 9 | +from typing import List, Dict |
| 10 | +from queue import Queue, Empty |
| 11 | + |
| 12 | +from common.utils.common import group_by |
| 13 | + |
| 14 | + |
| 15 | +class Content: |
| 16 | + def __init__(self, content: str, reasoning_content: str, **kwargs): |
| 17 | + """ |
| 18 | + 内容 |
| 19 | + @param content: ai响应内容 |
| 20 | + @param reasoning_content:思考过程 |
| 21 | + @param kwargs: 其他参数 |
| 22 | + """ |
| 23 | + self.content = content |
| 24 | + self.reasoning_content = reasoning_content |
| 25 | + for key in kwargs: |
| 26 | + self.__setattr__(key, kwargs.get(key)) |
| 27 | + |
| 28 | + |
| 29 | +class Chunk: |
| 30 | + |
| 31 | + def __init__(self, runtime_id: str, node_id: str, node_name: str, content: Content, node_data, children, loop_index, |
| 32 | + **kwargs): |
| 33 | + """ |
| 34 | +
|
| 35 | + @param runtime_id: 运行时id |
| 36 | + @param node_id: 节点id |
| 37 | + @param node_name: 节点名称 |
| 38 | + @param loop_index: 循环下标 |
| 39 | + @param children: 子块 |
| 40 | + @param node_data 节点数据 |
| 41 | + @param content: 内容 |
| 42 | + """ |
| 43 | + self.runtime_id = runtime_id |
| 44 | + self.node_id = node_id |
| 45 | + self.node_name = node_name |
| 46 | + self.loop_index = loop_index |
| 47 | + self.children = children |
| 48 | + self.content = content |
| 49 | + self.node_data = node_data |
| 50 | + for key in kwargs: |
| 51 | + self.__setattr__(key, kwargs.get(key)) |
| 52 | + |
| 53 | + |
| 54 | +class Channel: |
| 55 | + """ |
| 56 | + 对话管道 |
| 57 | + """ |
| 58 | + messages = Queue() |
| 59 | + is_end = False |
| 60 | + |
| 61 | + def write(self, message): |
| 62 | + if isinstance(message, Channel) | isinstance(message, Chunk): |
| 63 | + if self.is_end: |
| 64 | + raise "通道已关闭" |
| 65 | + self.messages.put(message) |
| 66 | + else: |
| 67 | + raise "不支持的管道参数" |
| 68 | + |
| 69 | + def end(self): |
| 70 | + self.is_end = True |
| 71 | + return self.messages.put(None) |
| 72 | + |
| 73 | + def pop(self): |
| 74 | + if self.is_end: |
| 75 | + return self.messages.get_nowait() |
| 76 | + return self.messages.get() |
| 77 | + |
| 78 | + def generator(self): |
| 79 | + while True: |
| 80 | + try: |
| 81 | + message = self.pop() |
| 82 | + if message: |
| 83 | + if isinstance(message, Channel): |
| 84 | + for chunk in message.generator(): |
| 85 | + yield chunk |
| 86 | + else: |
| 87 | + yield message |
| 88 | + except Empty: |
| 89 | + return |
| 90 | + |
| 91 | + |
| 92 | +class Node: |
| 93 | + |
| 94 | + def __init__(self, _id: str, _type: str, x: int, y: int, properties: dict, **kwargs): |
| 95 | + """ |
| 96 | +
|
| 97 | + @param _id: 节点id |
| 98 | + @param _type: 类型 |
| 99 | + @param x: 节点x轴位置 |
| 100 | + @param y: 节点y轴位置 |
| 101 | + @param properties: |
| 102 | + @param kwargs: |
| 103 | + """ |
| 104 | + self.id = _id |
| 105 | + self.type = _type |
| 106 | + self.x = x |
| 107 | + self.y = y |
| 108 | + self.properties = properties |
| 109 | + for keyword in kwargs: |
| 110 | + self.__setattr__(keyword, kwargs.get(keyword)) |
| 111 | + |
| 112 | + |
| 113 | +class Edge: |
| 114 | + def __init__(self, _id: str, _type: str, sourceNodeId: str, targetNodeId: str, **keywords): |
| 115 | + """ |
| 116 | + 线 |
| 117 | + @param _id: 线id |
| 118 | + @param _type: 线类型 |
| 119 | + @param sourceNodeId: |
| 120 | + @param targetNodeId: |
| 121 | + @param keywords: |
| 122 | + """ |
| 123 | + self.id = _id |
| 124 | + self.type = _type |
| 125 | + self.sourceNodeId = sourceNodeId |
| 126 | + self.targetNodeId = targetNodeId |
| 127 | + for keyword in keywords: |
| 128 | + self.__setattr__(keyword, keywords.get(keyword)) |
| 129 | + |
| 130 | + |
| 131 | +class EdgeNode: |
| 132 | + edge: Edge |
| 133 | + node: Node |
| 134 | + |
| 135 | + def __init__(self, edge, node): |
| 136 | + self.edge = edge |
| 137 | + self.node = node |
| 138 | + |
| 139 | + |
| 140 | +class Workflow: |
| 141 | + """ |
| 142 | + 节点列表 |
| 143 | + """ |
| 144 | + nodes: List[Node] |
| 145 | + """ |
| 146 | + 线列表 |
| 147 | + """ |
| 148 | + edges: List[Edge] |
| 149 | + """ |
| 150 | + 节点id:node |
| 151 | + """ |
| 152 | + node_map: Dict[str, Node] |
| 153 | + """ |
| 154 | + 节点id:当前节点id上面的所有节点 |
| 155 | + """ |
| 156 | + up_node_map: Dict[str, List[EdgeNode]] |
| 157 | + """ |
| 158 | + 节点id:当前节点id下面的所有节点 |
| 159 | + """ |
| 160 | + next_node_map: Dict[str, List[EdgeNode]] |
| 161 | + |
| 162 | + def __init__(self, nodes: List[Node], edges: List[Edge]): |
| 163 | + self.nodes = nodes |
| 164 | + self.edges = edges |
| 165 | + self.node_map = {node.id: node for node in nodes} |
| 166 | + |
| 167 | + self.up_node_map = {key: [EdgeNode(edge, self.node_map.get(edge.sourceNodeId)) for |
| 168 | + edge in edges] for |
| 169 | + key, edges in |
| 170 | + group_by(edges, key=lambda edge: edge.targetNodeId).items()} |
| 171 | + |
| 172 | + self.next_node_map = {key: [EdgeNode(edge, self.node_map.get(edge.targetNodeId)) for edge in edges] for |
| 173 | + key, edges in |
| 174 | + group_by(edges, key=lambda edge: edge.sourceNodeId).items()} |
| 175 | + |
| 176 | + def get_node(self, node_id): |
| 177 | + """ |
| 178 | + 根据node_id 获取节点信息 |
| 179 | + @param node_id: node_id |
| 180 | + @return: 节点信息 |
| 181 | + """ |
| 182 | + return self.node_map.get(node_id) |
| 183 | + |
| 184 | + def get_up_edge_nodes(self, node_id) -> List[EdgeNode]: |
| 185 | + """ |
| 186 | + 根据节点id 获取当前连接前置节点和连线 |
| 187 | + @param node_id: 节点id |
| 188 | + @return: 节点连线列表 |
| 189 | + """ |
| 190 | + return self.up_node_map.get(node_id) |
| 191 | + |
| 192 | + def get_next_edge_nodes(self, node_id) -> List[EdgeNode]: |
| 193 | + """ |
| 194 | + 根据节点id 获取当前连接目标节点和连线 |
| 195 | + @param node_id: 节点id |
| 196 | + @return: 节点连线列表 |
| 197 | + """ |
| 198 | + return self.next_node_map.get(node_id) |
| 199 | + |
| 200 | + def get_up_nodes(self, node_id) -> List[Node]: |
| 201 | + """ |
| 202 | + 根据节点id 获取当前连接前置节点 |
| 203 | + @param node_id: 节点id |
| 204 | + @return: 节点列表 |
| 205 | + """ |
| 206 | + return [en.node for en in self.up_node_map.get(node_id)] |
| 207 | + |
| 208 | + def get_next_nodes(self, node_id) -> List[Node]: |
| 209 | + """ |
| 210 | + 根据节点id 获取当前连接目标节点 |
| 211 | + @param node_id: 节点id |
| 212 | + @return: 节点列表 |
| 213 | + """ |
| 214 | + return [en.node for en in self.next_node_map.get(node_id, [])] |
0 commit comments