review comments

Author: zbirenbaum

src/agents/run.py

@@ -905,7 +905,10 @@ async def _run_input_guardrails_with_queue(
                 t.cancel()
             raise
 
+        # Store the full set of input guardrail results on the streamed result
+        # and return them so callers awaiting this task can receive the list.
         streamed_result.input_guardrail_results = guardrail_results
+        return guardrail_results
 
     @classmethod
     async def _start_streaming(
@@ -1138,11 +1141,13 @@ async def _start_streaming(
 
             streamed_result.is_complete = True
         finally:
-            if task := streamed_result._input_guardrails_task:
+            if streamed_result._input_guardrails_task:
                 try:
-                    streamed_result.input_guardrail_results = await task
-                except Exception:
-                    streamed_result.input_guardrail_results = []
+                    await streamed_result._input_guardrails_task
+                except Exception as e:
+                    logger.debug(
+                        f"Error in streamed_result finalize for agent {current_agent.name} - {e}"
+                    )
             if current_span:
                 current_span.finish(reset_current=True)
             if streamed_result.trace: