diff --git a/src/main.py b/src/main.py index c97bb22a..2412ce2a 100644 --- a/src/main.py +++ b/src/main.py @@ -315,7 +315,7 @@ async def _ingest_default_documents_langflow(services, file_paths): # Prepare tweaks for default documents with anonymous user metadata default_tweaks = { - "OpenSearchHybrid-Ve6bS": { + "OpenSearchVectorStoreComponent-YnJox": { "docs_metadata": [ {"key": "owner", "value": None}, {"key": "owner_name", "value": anonymous_user.name}, diff --git a/src/models/processors.py b/src/models/processors.py index a817f8d4..7fc6b3a4 100644 --- a/src/models/processors.py +++ b/src/models/processors.py @@ -411,9 +411,9 @@ class LangflowFileProcessor(TaskProcessor): if metadata_tweaks: # Initialize the OpenSearch component tweaks if not already present - if "OpenSearchHybrid-Ve6bS" not in final_tweaks: - final_tweaks["OpenSearchHybrid-Ve6bS"] = {} - final_tweaks["OpenSearchHybrid-Ve6bS"]["docs_metadata"] = metadata_tweaks + if "OpenSearchVectorStoreComponent-YnJox" not in final_tweaks: + final_tweaks["OpenSearchVectorStoreComponent-YnJox"] = {} + final_tweaks["OpenSearchVectorStoreComponent-YnJox"]["docs_metadata"] = metadata_tweaks # Process file using langflow service result = await self.langflow_file_service.upload_and_ingest_file( diff --git a/src/services/langflow_file_service.py b/src/services/langflow_file_service.py index 5b84d523..71867c33 100644 --- a/src/services/langflow_file_service.py +++ b/src/services/langflow_file_service.py @@ -91,7 +91,7 @@ class LangflowFileService: # Pass JWT token via tweaks using the x-langflow-global-var- pattern if jwt_token: # Using the global variable pattern that Langflow expects for OpenSearch components - tweaks["OpenSearchHybrid-Ve6bS"] = {"jwt_token": jwt_token} + tweaks["OpenSearchVectorStoreComponent-YnJox"] = {"jwt_token": jwt_token} logger.debug("[LF] Added JWT token to tweaks for OpenSearch components") else: logger.warning("[LF] No JWT token provided") @@ -109,9 +109,9 @@ class LangflowFileService: if metadata_tweaks: # Initialize the OpenSearch component tweaks if not already present - if "OpenSearchHybrid-Ve6bS" not in tweaks: - tweaks["OpenSearchHybrid-Ve6bS"] = {} - tweaks["OpenSearchHybrid-Ve6bS"]["docs_metadata"] = metadata_tweaks + if "OpenSearchVectorStoreComponent-YnJox" not in tweaks: + tweaks["OpenSearchVectorStoreComponent-YnJox"] = {} + tweaks["OpenSearchVectorStoreComponent-YnJox"]["docs_metadata"] = metadata_tweaks logger.debug( "[LF] Added metadata to tweaks", metadata_count=len(metadata_tweaks) )