Compare commits

...

2 Commits

Author SHA1 Message Date
-LAN-
eaba129e98 Merge branch 'main' into fix/skip-invalid-source_node_id-in-end-stream-generator-router
Signed-off-by: -LAN- <laipz8200@outlook.com>
2024-12-23 15:09:48 +08:00
-LAN-
75d2a0ec32 fix: skip invalid source_node_id in end stream generator router
Signed-off-by: -LAN- <laipz8200@outlook.com>
2024-12-23 15:08:00 +08:00

View File

@@ -135,6 +135,7 @@ class EndStreamGeneratorRouter:
reverse_edges = reverse_edge_mapping.get(current_node_id, [])
for edge in reverse_edges:
source_node_id = edge.source_node_id
# found sometimes source_node_id is not in node_id_config_mapping, temporary fix by skip it
if source_node_id not in node_id_config_mapping:
continue
source_node_type = node_id_config_mapping[source_node_id].get("data", {}).get("type")