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

retry get config better startup error handling, #485

Browse Source
This commit is contained in:
Simon
2023-06-23 00:15:07 +07:00
parent 72a98b0473
commit 061c653bce
1 changed files with 13 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
tubearchivist/home/src/ta/config.py
View File

@@ -8,6 +8,7 @@ import json
import os import os
import re import re
from random import randint from random import randint
from time import sleep
import requests import requests
from celery.schedules import crontab from celery.schedules import crontab
@@ -67,11 +68,19 @@ class AppConfig:
@staticmethod @staticmethod
def get_config_redis(): def get_config_redis():
"""read config json set from redis to overwrite defaults""" """read config json set from redis to overwrite defaults"""
config = RedisArchivist().get_message("config") for i in range(10):
if not list(config.values())[0]: try:
return False config = RedisArchivist().get_message("config")
if not list(config.values())[0]:
return False
return config return config
except Exception: # pylint: disable=broad-except
print(f"... Redis connection failed, retry [{i}/10]")
sleep(3)
raise ConnectionError("failed to connect to redis")
def update_config(self, form_post): def update_config(self, form_post):
"""update config values from settings form""" """update config values from settings form"""