根据节点id 获取当前连接目标节点 @param node_id: 节点id @return: 节点列表
(self, node_id)
| 177 | return [en.node for en in (self.up_node_map.get(node_id) or [])] |
| 178 | |
| 179 | def get_next_nodes(self, node_id) -> List[Node]: |
| 180 | """ |
| 181 | 根据节点id 获取当前连接目标节点 |
| 182 | @param node_id: 节点id |
| 183 | @return: 节点列表 |
| 184 | """ |
| 185 | return [en.node for en in self.next_node_map.get(node_id, [])] |
| 186 | |
| 187 | @staticmethod |
| 188 | def new_instance(flow_obj: Dict, workflow_mode: WorkflowMode = WorkflowMode.APPLICATION): |