skip emitting deltas

This commit is contained in:
Swapna Lekkala 2025-10-15 06:28:06 -07:00
parent eb7dcebb25
commit fc960a35dd

View file

@ -601,13 +601,15 @@ class StreamingResponseOrchestrator:
sequence_number=self.sequence_number, sequence_number=self.sequence_number,
) )
self.sequence_number += 1 self.sequence_number += 1
yield OpenAIResponseObjectStreamResponseOutputTextDelta( # Skip Emitting text content delta event if guardrails are configured, only emits chunks after guardrails are applied
content_index=content_index, if not self.guardrail_ids:
delta=chunk_choice.delta.content, yield OpenAIResponseObjectStreamResponseOutputTextDelta(
item_id=message_item_id, content_index=content_index,
output_index=message_output_index, delta=chunk_choice.delta.content,
sequence_number=self.sequence_number, item_id=message_item_id,
) output_index=message_output_index,
sequence_number=self.sequence_number,
)
# Collect content for final response # Collect content for final response
chat_response_content.append(chunk_choice.delta.content or "") chat_response_content.append(chunk_choice.delta.content or "")