From 1d3926af27464d7a9678dd9ca175c7766e8dbd8e Mon Sep 17 00:00:00 2001
From: Nuno Campos <nuno@langchain.dev>
Date: Tue, 11 Mar 2025 18:13:36 -0700
Subject: [PATCH] Fix kafka

---
 libs/langgraph/langgraph/pregel/loop.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/libs/langgraph/langgraph/pregel/loop.py b/libs/langgraph/langgraph/pregel/loop.py
index 169943718..66f0a60f5 100644
--- a/libs/langgraph/langgraph/pregel/loop.py
+++ b/libs/langgraph/langgraph/pregel/loop.py
@@ -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(