From 0332e1c692aac3b4a6f0214f0d6b4727d5367ac5 Mon Sep 17 00:00:00 2001 From: admin Date: Wed, 30 Apr 2025 14:11:18 +0300 Subject: [PATCH] refactor: simplify stock sending logic by processing chunks sequentially --- marketplaces/wildberries.py | 21 ++++++++++++--------- 1 file changed, 12 insertions(+), 9 deletions(-) diff --git a/marketplaces/wildberries.py b/marketplaces/wildberries.py index 3bd663a..1311977 100644 --- a/marketplaces/wildberries.py +++ b/marketplaces/wildberries.py @@ -70,13 +70,16 @@ class WildberriesMarketplaceApi(BaseMarketplaceApi): f'Exception occurred while sending stocks to marketplace ID [{self.marketplace.id}]: {str(e)}') return False - tasks = [send_stock_chunk(chunk) for chunk in chunks] - first_request = tasks[0] - first_response = await first_request - if not first_response: - logging.error(f'Skipping marketplace [{self.marketplace.id}] because first request was unsuccessful') - await self.session.close() - return - - await asyncio.gather(*tasks[1:]) + for chunk in chunks: + await send_stock_chunk(chunk) + await asyncio.sleep(0.2) + # tasks = [send_stock_chunk(chunk) for chunk in chunks] + # first_request = tasks[0] + # first_response = await first_request + # if not first_response: + # logging.error(f'Skipping marketplace [{self.marketplace.id}] because first request was unsuccessful') + # await self.session.close() + # return + # + # await asyncio.gather(*tasks[1:]) await self.session.close()