norohind/jubilant-system-core
1
0
Fork 0
mirror of https://github.com/norohind/jubilant-system-core.git synced 2025-04-14 02:27:13 +03:00
Code Issues Projects Releases Wiki Activity

HookSystem._last_records: add retry logic

Browse Source
This commit is contained in:
norohind 2022-04-19 16:02:51 +03:00
parent 9ed6e786e6
commit c410b9a120
Signed by: norohind
GPG Key ID: 01C3BECC26FB59E1
1 changed files with 17 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
HookSystem.py
View File

@ -5,6 +5,8 @@ from Hook import Hook
import importlib.machinery
import HookUtils
import copy
from loguru import logger
import threading
def check_int(func: callable) -> callable:
@ -17,10 +19,21 @@ def check_int(func: callable) -> callable:
def _last_records(operation_id: int, limit: int) -> list[dict]:
return Hook.get_db().execute(
HookUtils.SQL_REQUESTS.GET_HISTORICAL_INFO,
{'limit': limit, 'operation_id': operation_id}
).fetchall()
last_exception: Exception | None = None
for retry in range(0, 3):
try:
return Hook.get_db().execute(
HookUtils.SQL_REQUESTS.GET_HISTORICAL_INFO,
{'limit': limit, 'operation_id': operation_id}
).fetchall()
except Exception as e:
logger.opt(exception=True).warning(f'Exception in {threading.current_thread().name}, retry: {retry}')
last_exception = e
continue
raise last_exception
class HookSystem: