fix: forward elasticsearch timeout

neo4j-app/neo4j_app/core/config.py

@@ -6,7 +6,7 @@
 import sys
 from configparser import ConfigParser
 from logging.handlers import SysLogHandler
-from typing import Dict, List, Optional, TextIO
+from typing import Dict, List, Optional, TextIO, Union
 
 import neo4j
 from pydantic import Field, validator
@@ -37,7 +37,7 @@ class AppConfig(LowerCamelCaseModel, IgnoreExtraModel):
     es_doc_type_field: str = Field(alias="docTypeField", default="type")
     es_default_page_size: int = 1000
     es_max_concurrency: int = 5
-    es_timeout: int = "1m"
+    es_timeout_s: Union[int, float] = 60 * 5
     es_keep_alive: str = "1m"
     neo4j_app_host: str = "127.0.0.1"
     neo4j_app_log_level: str = "INFO"
@@ -142,14 +142,13 @@ def to_neo4j_driver(self) -> neo4j.AsyncDriver:
         )
         return driver
 
-    # TODO: change this to output ESClientMixin...
     def to_es_client(self) -> ESClientABC:
         client_cls = OSClient if self.neo4j_app_uses_opensearch else ESClient
-        # TODO: read the index name in a secure manner...
         client = client_cls(
             hosts=[self.elasticsearch_address],
             pagination=self.es_default_page_size,
             max_concurrency=self.es_max_concurrency,
+            timeout=self.es_timeout_s,
         )
         return client