multilingual

semantic_search/all_search_execute.py

@@ -160,7 +160,7 @@ def handler(input_,session_id):
             print("Hybrid Rerank Search Pipeline updated: "+str(r.status_code))
         
             ######## Updating opensearch_translation_pipeline Search pipeline #######   
-            opensearch_translation_pipeline = (requests.get(host+'_search/pipeline/ml_inference_for_vector_search_and_language_translation', auth=awsauth,headers=headers)).text
+            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
@@ -168,7 +168,7 @@ def handler(input_,session_id):
             print("translation hybrid Search Pipeline updated: "+str(r.status_code))
 
             ######## Updating opensearch_translation_pipeline_with_rerank Search pipeline #######
-            opensearch_translation_pipeline_with_rerank = (requests.get(host+'_search/pipeline/ml_inference_for_vector_search_and_language_translation_with_rerank', auth=awsauth,headers=headers)).text
+            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