fix: blocking guardrails now prevent agent execution in streaming mode

Author: RVV-karma

src/agents/run.py

@@ -928,7 +928,9 @@ async def _run_input_guardrails_with_queue(
                 t.cancel()
             raise
 
-        streamed_result.input_guardrail_results = guardrail_results
+        streamed_result.input_guardrail_results = (
+            streamed_result.input_guardrail_results + guardrail_results
+        )
 
     @classmethod
     async def _start_streaming(
@@ -1029,7 +1031,7 @@ async def _start_streaming(
                     ]
                     parallel_guardrails = [g for g in all_input_guardrails if g.run_in_parallel]
 
-                    # Run sequential guardrails first (will raise exception if tripwire triggered).
+                    # Run sequential guardrails first.
                     if sequential_guardrails:
                         await cls._run_input_guardrails_with_queue(
                             starting_agent,
@@ -1039,6 +1041,10 @@ async def _start_streaming(
                             streamed_result,
                             current_span,
                         )
+                        # Check if any blocking guardrail triggered and raise before starting agent.
+                        for result in streamed_result.input_guardrail_results:
+                            if result.output.tripwire_triggered:
+                                raise InputGuardrailTripwireTriggered(result)
 
                     # Run parallel guardrails in background.
                     streamed_result._input_guardrails_task = asyncio.create_task(