From b5c046ea256f3b545315166db97de2fe7b0a23b0 Mon Sep 17 00:00:00 2001
From: jsdio <jsdio@jsdio.ru>
Date: Tue, 6 Jun 2023 11:28:44 +0300
Subject: [PATCH] =?UTF-8?q?=D0=94=D0=BE=D0=B1=D0=B0=D0=B2=D0=B8=D0=BB=20?=
 =?UTF-8?q?=D0=B8=D1=81=D0=BA=D0=BB=D1=8E=D1=87=D0=B5=D0=BD=D0=B8=D0=B5=20?=
 =?UTF-8?q?ClientConnectorError?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/loader.py | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/loader.py b/src/loader.py
index bbced86..1e9f5c0 100644
--- a/src/loader.py
+++ b/src/loader.py
@@ -21,8 +21,8 @@ class EtlLoader:
         self.etl = EtlConfig()
         self.api_config = ApiConfig()
 
-    @backoff.on_exception(backoff.expo, (asyncio.TimeoutError, ), base=2, factor=1,
-                          max_value=etl_config.max_wait_size, max_tries=None)
+    @backoff.on_exception(backoff.expo, (asyncio.TimeoutError, aiohttp.ClientConnectorError), base=2, factor=1,
+                          max_value=int(etl_config.max_wait_size), max_tries=None)
     async def load_data(self, state: State, abitr: Abitr, iblock_id: int, storage: BaseStorage):
         async with aiohttp.ClientSession() as session:
             logging.info(f"Информация об абитуриенте: {abitr.FIO}")
@@ -33,7 +33,7 @@ class EtlLoader:
             async with session.post(
                     url=f"{self.etl.protocol}://{self.etl.host}:{self.etl.port}",
                     data=data_dict,
-                    timeout=aiohttp.ClientTimeout(total=30)
+                    timeout=aiohttp.ClientTimeout(total=int(etl_config.max_wait_size))
             ) as response:
                 pass
             state.set_state(f'iblock_{iblock_id}', abitr.ID)