Initial commit using ElasticSearch's retry_on_conflict feature on _up…

…date operations.
dbmi-pitt · Jul 18, 2024 · 5dc106f · 5dc106f
1 parent 1bc7507
commit 5dc106f
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/src/app.py b/src/app.py
@@ -1384,9 +1384,13 @@ def create_request_headers_for_auth(self, token):
         return headers_dict
 
     def init_translator(self, token):
-        if self.ubkg_instance is None:
-            return self.translator_module.Translator(self.INDICES, self.APP_CLIENT_ID, self.APP_CLIENT_SECRET, token, self.ONTOLOGY_API_BASE_URL)
-        return self.translator_module.Translator(self.INDICES, self.APP_CLIENT_ID, self.APP_CLIENT_SECRET, token, self.ubkg_instance)
+        ont_api_base_url = self.ONTOLOGY_API_BASE_URL if self.ubkg_instance is None else self.ubkg_instance
+        return self.translator_module.Translator(   indices=self.INDICES
+                                                    , app_client_id=self.APP_CLIENT_ID
+                                                    , app_client_secret=self.APP_CLIENT_SECRET
+                                                    , token=token
+                                                    , ontology_api_base_url=ont_api_base_url
+                                                    , es_retry_on_conflict_freq=self.ES_RETRY_ON_CONFLICT_FREQ)
 
     # Get a list of filtered Elasticsearch indices to expose to end users without the prefix
     def get_filtered_indices(self):