diff --git a/src/google/adk/flows/llm_flows/base_llm_flow.py b/src/google/adk/flows/llm_flows/base_llm_flow.py index 624273c..9b9b156 100644 --- a/src/google/adk/flows/llm_flows/base_llm_flow.py +++ b/src/google/adk/flows/llm_flows/base_llm_flow.py @@ -281,6 +281,12 @@ class BaseLlmFlow(ABC): yield event if not last_event or last_event.is_final_response(): break + if last_event.partial: + # TODO: handle this in BaseLlm level. + raise ValueError( + f"Last event shouldn't be partial. LLM max output limit may be" + f' reached.' + ) async def _run_one_step_async( self,