Skip to content

Commit 203320f

Browse files
authored
Fix streaming prompt-feedback handling
Signed-off-by: Johan Grande <nahoj@crans.org>
1 parent b8c5cb8 commit 203320f

File tree

1 file changed

+2
-7
lines changed

1 file changed

+2
-7
lines changed

pipelines/google/google_gemini.py

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1854,13 +1854,8 @@ async def emit_chat_event(event_type: str, data: Dict[str, Any]) -> None:
18541854
# Check for safety feedback or empty chunks
18551855
if not chunk.candidates:
18561856
# Check prompt feedback
1857-
if (
1858-
response_iterator.prompt_feedback
1859-
and response_iterator.prompt_feedback.block_reason
1860-
):
1861-
block_reason = (
1862-
response_iterator.prompt_feedback.block_reason.name
1863-
)
1857+
if chunk.prompt_feedback and chunk.prompt_feedback.block_reason:
1858+
block_reason = chunk.prompt_feedback.block_reason.name
18641859
message = f"[Blocked due to Prompt Safety: {block_reason}]"
18651860
await emit_chat_event(
18661861
"chat:finish",

0 commit comments

Comments
 (0)