public/tubearchivist
1
0
Fork 0
mirror of https://git.vectorsigma.ru/public/tubearchivist.git synced 2026-08-08 16:19:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix startup race condition cluster health

Browse Source
This commit is contained in:
simon
2023-05-20 19:29:32 +07:00
parent 139d20560f
commit c4e2332b83
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
tubearchivist/config/management/commands/ta_connection.py
View File

@@ -86,6 +86,8 @@ class Command(BaseCommand):
continue continue
if status_code and status_code == 200: if status_code and status_code == 200:
path = "_cluster/health?wait_for_status=yellow&timeout=30s"
_, _ = ElasticWrap(path).get()
self.stdout.write( self.stdout.write(
self.style.SUCCESS(" ✓ ES connection established") self.style.SUCCESS(" ✓ ES connection established")
) )
@@ -116,7 +118,7 @@ class Command(BaseCommand):
return return
message = ( message = (
" 🗙 ES connection failed. " " 🗙 ES version check failed. "
+ f"Expected {self.MIN_MAJOR}.{self.MIN_MINOR} but got {version}" + f"Expected {self.MIN_MAJOR}.{self.MIN_MINOR} but got {version}"
) )
self.stdout.write(self.style.ERROR(f"{message}")) self.stdout.write(self.style.ERROR(f"{message}"))