Merge pull request #26 from zeerayne/aiopg-retries

[Backup scenario] aiopg retries when checking pg version

Author: zeerayne

.gitignore

@@ -139,6 +139,9 @@ dmypy.json
 # All deb packages
 *.deb
 
+# ruff cache
+.ruff_cache
+
 # Postgres datadir
 .postgres-data
 # Ragent datadir

.pre-commit-config.yaml

@@ -1,7 +1,7 @@
 repos:
 - repo: https://github.com/astral-sh/ruff-pre-commit
   # Ruff version.
-  rev: v0.8.2
+  rev: v0.9.1
   hooks:
     # Run the linter.
     - id: ruff

README.md

@@ -127,7 +127,7 @@ TIP: для работы с путями в шаблонном файле нас
 |Параметр|Описание|
 |-------:|:-------|
 |`V8_CLUSTER_ADMIN_CREDENTIALS`|Учетные данные администратора кластера 1С Предприятие|
-|`V8_CLUSTER_CONTROL_MODE     `|Режим взаимодействия с кластером 1С Предприятие: через COM-компоненту (`'com'`) или через клиент администрирования кластера (`'rac'`)|
+|`V8_CLUSTER_CONTROL_MODE`     |Режим взаимодействия с кластером 1С Предприятие: через COM-компоненту (`'com'`) или через клиент администрирования кластера (`'rac'`)|
 |`V8_INFOBASES_CREDENTIALS`    |Сопоставление с именами информационных баз, именами пользователей и паролями, которые будут использованы для подключения к информационным базам. Если информационная база не указана в списке в явном виде, для подклчения к ней будут использованы данные от записи `default`|
 |`V8_INFOBASES_EXCLUDE`        |Список с именами информационных баз, которые будут пропущены. Никакие операции с ними выполняться не будут|
 |`V8_INFOBASES_ONLY`           |Если список не пустой, все действия будут проводиться только с информационными базами, указанными в нём|

backup.py

@@ -128,13 +128,17 @@ async def _backup_pgdump(
     except (ValueError, KeyError) as e:
         log.error(f"<{ib_name}> {str(e)}")
         return core_models.InfoBaseBackupTaskResult(ib_name, False)
-
-    try:
-        pg_major_version = (await postgres.get_postgres_version(db_host, db_port, db_name, db_user, db_pwd)).major
-        blobs = "large-objects" if pg_major_version >= 16 else "blobs"
-    except (ConnectionRefusedError, CancelledError, TimeoutError) as e:
-        log.error(f"<{ib_name}> {str(e)}")
-        return core_models.InfoBaseBackupTaskResult(ib_name, False)
+    backup_retries = settings.BACKUP_RETRIES_PG
+    for i in range(0, backup_retries + 1):
+        try:
+            pg_major_version = (await postgres.get_postgres_version(db_host, db_port, db_name, db_user, db_pwd)).major
+            blobs = "large-objects" if pg_major_version >= 16 else "blobs"
+        except (ConnectionRefusedError, CancelledError, TimeoutError) as e:
+            if i == backup_retries:
+                log.error(f"<{ib_name}> {type(e)}: {e.message}")
+                return core_models.InfoBaseBackupTaskResult(ib_name, False)
+            else:
+                log.error(f"<{ib_name}> Postgres version check failed, retrying")
 
     ib_and_time_str = utils.get_ib_and_time_string(ib_name)
     backup_filename = os.path.join(
@@ -153,7 +157,6 @@ async def _backup_pgdump(
     pgdump_env["PGPASSWORD"] = db_pwd
     log.debug(f"<{ib_name}> Created pgdump command [{pgdump_command}]")
     # Делает резервную копию базы данных в *.pgdump файл
-    backup_retries = settings.BACKUP_RETRIES_PG
     # Добавляет 1 к количеству повторных попыток, потому что одну попытку всегда нужно делать
     for i in range(0, backup_retries + 1):
         try: