Avoid crash when a node in pending sends is removed

2026-09-07 18:27:52 +02:00 · 2024-07-24 09:29:38 -07:00
parent 19f6f7d5ca
commit 8a20c6f7e4
1 changed files with 3 additions and 0 deletions
@@ -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():