From 8b55667c9465aba302852702e8374d19065a6d5f Mon Sep 17 00:00:00 2001 From: grucshetskyaleksei Date: Thu, 22 Jun 2023 02:48:20 +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=BE=D0=B1=D1=80=D0=B0=D0=B1=D0=BE=D1=82=D0=BA=D1=83=20Server?= =?UTF-8?q?DisconnectedError=20=D0=B2=20backoff?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/loader.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/loader.py b/src/loader.py index 9e3dcce..45b97f3 100644 --- a/src/loader.py +++ b/src/loader.py @@ -22,7 +22,8 @@ class EtlLoader: self.etl = EtlConfig() self.api_config = ApiConfig() - @backoff.on_exception(backoff.expo, (asyncio.TimeoutError, aiohttp.ClientConnectorError,), base=2, factor=1, + @backoff.on_exception(backoff.expo, (asyncio.TimeoutError, aiohttp.ClientConnectorError, + aiohttp.ServerDisconnectedError), base=2, factor=1, max_value=int(misc_settings.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: