internal change

PiperOrigin-RevId: 830439630

Author: aelissee

genai_processors/core/function_calling.py

@@ -510,9 +510,7 @@ async def call(
             input_queue.put_nowait(content_api.END_OF_TURN)
             state.has_new_fn_calls = False
             state.schedule_model_call = False
-        elif (
-            state.schedule_model_call and not state.model_outputting
-        ):  # or state.has_new_fn_calls:
+        elif state.schedule_model_call and not state.model_outputting:
           input_queue.put_nowait(content_api.END_OF_TURN)
           state.has_new_fn_calls = False
           state.schedule_model_call = False

genai_processors/core/web.py

@@ -97,8 +97,8 @@ async def call(
 
       # Iterate over the response chunks
       html_content = []
-      async for chunk in response.aiter_bytes():
-        html_content.append(chunk.decode(response.encoding or 'utf-8'))
+      async for chunk in response.aiter_text():
+        html_content.append(chunk)
       yield content_api.ProcessorPart(
           ''.join(html_content), mimetype=mime_types.TEXT_HTML
       )