Replaced deprecated stream service sources update call

This commit is contained in:
Utkarsh-Patel-13 2025-07-21 09:54:33 -07:00
parent dd7768206c
commit 53a79d9b65

View file

@ -810,8 +810,7 @@ async def fetch_relevant_documents(
# After all sources are collected and deduplicated, stream them
if streaming_service and writer:
streaming_service.only_update_sources(deduplicated_sources)
writer({"yield_value": streaming_service._format_annotations()})
writer({"yield_value": streaming_service.format_sources_delta(deduplicated_sources)})
# Deduplicate raw documents based on chunk_id or content
seen_chunk_ids = set()