From 5842d80350d6b46cb67ca68f2ca72b2248bb2ac2 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Nikola=20Milosavljevi=C4=87?=
 <116065832+nikola-milosa@users.noreply.github.com>
Date: Mon, 22 Jan 2024 09:58:50 +0100
Subject: [PATCH] fix(k8s): adding timeout option (#79)

---
 .../cursor-initializator-elastic.py                             | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/k8s/cursor-initializator-elastic/cursor-initializator-elastic.py b/k8s/cursor-initializator-elastic/cursor-initializator-elastic.py
index 623dbf1b..1afa339c 100644
--- a/k8s/cursor-initializator-elastic/cursor-initializator-elastic.py
+++ b/k8s/cursor-initializator-elastic/cursor-initializator-elastic.py
@@ -34,7 +34,7 @@ def main():
     logger = get_logger()
 
     logger.info("Initializing elastic client with url: %s", args.elastic_url)
-    client = Elasticsearch(args.elastic_url, request_timeout=args.timeout)
+    client = Elasticsearch(args.elastic_url, timeout=args.timeout, retry_on_timeout=True, max_retries=3)
 
     indices = [i for i in list(client.indices.get(index=args.index_pattern)) if not i.startswith(".")]