Merge pull request #1119 from langchain-ai/nc/24jul/avoid-crash-missing-node

Avoid crash when a node in pending sends is removed
This commit is contained in:
Nuno Campos
2024-07-24 09:41:20 -07:00
committed by GitHub
+3
View File
@@ -257,6 +257,9 @@ def prepare_next_tasks(
if not isinstance(packet, Send):
logger.warn(f"Ignoring invalid packet type {type(packet)} in pending sends")
continue
if packet.node not in processes:
logger.warn(f"Ignoring unknown node name {packet.node} in pending sends")
continue
if for_execution:
proc = processes[packet.node]
if node := proc.get_node():