don't clear pending packets when just viewing

This commit is contained in:
Nuno Campos
2024-05-30 17:00:35 -07:00
parent dc9c7254e7
commit 683fac83dc
+2 -1
View File
@@ -1632,7 +1632,8 @@ def _prepare_next_tasks(
)
else:
tasks.append(PregelTaskDescription(packet.node, val))
checkpoint["pending_packets"].clear()
if for_execution:
checkpoint["pending_packets"].clear()
# Check if any processes should be run in next step
# If so, prepare the values to be passed to them
for name, proc in processes.items():