diff --git a/redisgraph/query_result.py b/redisgraph/query_result.py index 80f713d..474726b 100644 --- a/redisgraph/query_result.py +++ b/redisgraph/query_result.py @@ -111,7 +111,7 @@ def parse_edge(self, cell): src_node_id = float(cell[2]) dest_node_id = float(cell[3]) properties = self.parse_entity_properties(cell[4]) - return Edge(src_node_id, relation, dest_node_id, properties=properties) + return Edge(src_node_id, relation, dest_node_id, edge_id=edge_id, properties=properties) def parse_scalar(self, cell): scalar_type = int(cell[0])