fix: to prevent collisions incase of fallback which should never happen

This commit is contained in:
DESKTOP-RTLN3BA\$punk 2025-06-04 17:30:15 -07:00
parent 52a9ad04bd
commit ef252e821e

View file

@ -17,7 +17,7 @@ class ConnectorService:
self.chunk_retriever = ChucksHybridSearchRetriever(session)
self.document_retriever = DocumentHybridSearchRetriever(session)
self.user_id = user_id
self.source_id_counter = 1
self.source_id_counter = 100000 # High starting value to avoid collisions with existing IDs
self.counter_lock = asyncio.Lock() # Lock to protect counter in multithreaded environments
async def initialize_counter(self):