jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

changed request retry parameter

Browse source
This commit is contained in:
MauricioGarciaS 2024-04-17 15:09:55 +02:00
parent 90e11028cf
commit cbebe80c99
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
ee/quickwit/consumer.py
View file

@ -13,7 +13,7 @@ QUICKWIT_PORT = config('QUICKWIT_PORT', default=7280, cast=int)
#decryption = config('encrypted', cast=bool)
decryption = False
MessageCodec = None
max_retry=3
max_retry=2
Fetch, FetchEvent, PageEvent, GraphQ = None, None, None, None
if decryption:
from msgcodec.msgcodec import MessageCodec
@ -26,7 +26,7 @@ def _quickwit_ingest(index, data_list, retry=0):
except requests.exceptions.ConnectionError as e:
retry += 1
assert retry <= max_retry, f'[ENDPOINT CONNECTION FAIL] Failed to connect to endpoint http://localhost:{QUICKWIT_PORT}/api/v1/{index}/ingest\n{e}\n'
sleep(5*retry)
sleep(0.25*retry)
print(f"[ENDPOINT ERROR] Failed to connect to endpoint http://localhost:{QUICKWIT_PORT}/api/v1/{index}/ingest, retrying in {5*retry} seconds..\n")
return _quickwit_ingest(index, data_list, retry=retry)
return res