multilingual

semantic_search/all_search_execute.py

@@ -163,17 +163,17 @@ def handler(input_,session_id):
             opensearch_translation_pipeline = json.loads((requests.get(host+'_search/pipeline/ml_inference_for_vector_search_and_language_translation', auth=awsauth,headers=headers)).text)
             path = "_search/pipeline/ml_inference_for_vector_search_and_language_translation" 
             url = host + path
-            opensearch_translation_pipeline["phase_results_processors"] = hybrid_search_processor
+            opensearch_translation_pipeline["ml_inference_for_vector_search_and_language_translation"]["phase_results_processors"] = hybrid_search_processor
             print(opensearch_translation_pipeline)
-            r = requests.put(url, auth=awsauth, json=opensearch_translation_pipeline, headers=headers)
+            r = requests.put(url, auth=awsauth, json=opensearch_translation_pipeline["ml_inference_for_vector_search_and_language_translation"], headers=headers)
             print("translation hybrid Search Pipeline updated: "+str(r.status_code))
 
             ######## Updating opensearch_translation_pipeline_with_rerank Search pipeline #######
             opensearch_translation_pipeline_with_rerank = json.loads((requests.get(host+'_search/pipeline/ml_inference_for_vector_search_and_language_translation_with_rerank', auth=awsauth,headers=headers)).text)
             path = "_search/pipeline/ml_inference_for_vector_search_and_language_translation_with_rerank" 
             url = host + path
-            opensearch_translation_pipeline_with_rerank["phase_results_processors"] = hybrid_search_processor
-            r = requests.put(url, auth=awsauth, json=opensearch_translation_pipeline_with_rerank, headers=headers)
+            opensearch_translation_pipeline_with_rerank["opensearch_translation_pipeline_with_rerank"]["phase_results_processors"] = hybrid_search_processor
+            r = requests.put(url, auth=awsauth, json=opensearch_translation_pipeline_with_rerank["opensearch_translation_pipeline_with_rerank"], headers=headers)
             print("translation hybrid rerank Search Pipeline updated: "+str(r.status_code))
         ######## start of Applying LLM filters ####### 
     if(st.session_state.input_rewritten_query!=""):