This commit is contained in:
Nuno Campos
2024-10-11 14:28:16 -07:00
parent c6a450b857
commit 561aa3080e
+4 -1
View File
@@ -592,7 +592,10 @@ class PregelLoop:
self.output = read_channels(self.channels, self.output_keys)
if suppress:
# suppress interrupt
self._emit("updates", lambda: iter([{INTERRUPT: exc_value.args[0]}]))
self._emit(
"updates",
lambda: iter([{INTERRUPT: cast(GraphInterrupt, exc_value).args[0]}]),
)
return True
def _emit(