diff --git a/sender/ozon.py b/sender/ozon.py index a723d6e..4e4a620 100644 --- a/sender/ozon.py +++ b/sender/ozon.py @@ -37,6 +37,7 @@ class OzonStocksSender(BaseStocksSender): return SendStockStatus.SHOULD_RETRY return SendStockStatus.ERROR finally: + await response.close() await session.close() async def after_chunk_processed(self): return await asyncio.sleep(80 / 100) diff --git a/sender/wildberries.py b/sender/wildberries.py index 47845f5..430f67e 100644 --- a/sender/wildberries.py +++ b/sender/wildberries.py @@ -41,6 +41,7 @@ class WildberriesStocksSender(BaseStocksSender): self.remaining = int(headers.get('X-Ratelimit-Remaining', 0)) return SendStockStatus.SUCCESS finally: + await response.close() await session.close() async def after_chunk_processed(self): if self.remaining <= 0: diff --git a/sender/yandexmarket.py b/sender/yandexmarket.py index 172643f..1681d6d 100644 --- a/sender/yandexmarket.py +++ b/sender/yandexmarket.py @@ -40,6 +40,7 @@ class YandexmarketStocksSender(BaseStocksSender): logging.error(f'[{self.updater.marketplace.id}]: {response_text}') return SendStockStatus.ERROR finally: + await response.close() await session.close() async def after_chunk_processed(self):