jyapayne/langflow
1
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

🔧 refactor(base.py): add source_handle, target_handle, and target_param attributes to Edge class

Browse source 
The Edge class constructor now takes an additional parameter 'edge' which is a dictionary containing additional information about the edge. This information is used to set the source_handle, target_handle, and target_param attributes of the Edge class. This change allows for more flexibility and extensibility when working with edges in the graph.
🔧 refactor(base.py): add edge parameter to Edge class constructor to pass additional edge information
This commit is contained in:
Gabriel Luiz Freitas Almeida 2023-06-29 22:06:57 -03:00
commit 766ef28a0c
2 changed files with 8 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

8
src/backend/langflow/graph/edge/base.py
View file

@ -6,9 +6,15 @@ if TYPE_CHECKING:
class Edge: class Edge:
def __init__(self, source: "Vertex", target: "Vertex"): def __init__(self, source: "Vertex", target: "Vertex", edge: dict):
self.source: "Vertex" = source self.source: "Vertex" = source
self.target: "Vertex" = target self.target: "Vertex" = target
self.source_handle = edge.get("sourceHandle", "")
self.target_handle = edge.get("targetHandle", "")
# 'BaseLoader;BaseOutputParser|documents|PromptTemplate-zmTlD'
# target_param is documents
self.target_param = self.target_handle.split("|")[1]
self.validate_edge() self.validate_edge()
def validate_edge(self) -> None: def validate_edge(self) -> None:

2
src/backend/langflow/graph/graph/base.py
View file

@ -179,7 +179,7 @@ class Graph:
raise ValueError(f"Source node {edge['source']} not found") raise ValueError(f"Source node {edge['source']} not found")
if target is None: if target is None:
raise ValueError(f"Target node {edge['target']} not found") raise ValueError(f"Target node {edge['target']} not found")
edges.append(Edge(source, target)) edges.append(Edge(source, target, edge))
return edges return edges
def _get_vertex_class(self, node_type: str, node_lc_type: str) -> Type[Vertex]: def _get_vertex_class(self, node_type: str, node_lc_type: str) -> Type[Vertex]: