Fix kafka

This commit is contained in:
Nuno Campos
2025-03-11 18:13:36 -07:00
parent e566ed4b3f
commit 1d3926af27
+2
View File
@@ -687,6 +687,8 @@ class PregelLoop(LoopProtocol):
self.input = INPUT_DONE
elif CONFIG_KEY_RESUMING not in configurable:
raise EmptyInputError(f"Received no input for {input_keys}")
else:
self.input = INPUT_DONE
# update config
if not self.is_nested:
self.config = patch_configurable(