Update app.py

app.py

@@ -233,6 +233,9 @@ async def astream_processor(chain, inputs: dict) -> AsyncGenerator[str, None]:
         async for chunk in chain.astream(inputs):
             if isinstance(chunk, dict):
                 content = chunk.get('content', '')
+            elif hasattr(chunk, 'model_dump'):
+                # If the chunk has a model_dump method, convert it to a dictionary and get the content
+                content = chunk.model_dump().get('content', '')
             else:
                 content = str(chunk)
             yield content