Pass the message if coming from the __interrupt__ node

api.py

@@ -60,13 +60,13 @@ def event_stream(query: str, thread_id: Optional[str]=None, query_type: Optional
         raise ValueError(f"Invalid query type from frontend: {query_type}")
 
     for namespace, chunk in stream:
-        # Avoid streaming duplicate output by skipping the
-        # messages without namespace.
-        if not namespace:
-            continue
         node_name = list(chunk.keys())[0]
         print(f"Namespace -> {namespace}")
         print(f"Node name -> {node_name}")
+        # Avoid streaming duplicate output by skipping the
+        # messages without namespace.
+        if not namespace and not node_name == "__interrupt__":
+            continue
 
         if node_name == "__interrupt__":
             print(f"Waiting for human input")