prehistoric-systems/web
1
0
Fork 0
mirror of https://codeberg.org/Freedium-cfd/web.git synced 2026-03-11 09:04:37 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fixing sleep time

Browse source
This commit is contained in:
ZhymabekRoman 2024-03-09 20:37:08 +05:00
parent 5103f1bd0e
commit 07d9883c15
1 changed files with 18 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

37
core/medium_parser/core.py
View file

@ -106,27 +106,26 @@ class MediumParser:
while not post_data and attempt < retry:
try:
post_data, is_cache_used = await self.query_get(use_cache)
if not post_data:
reason = "No post data returned"
elif not isinstance(post_data, dict):
reason = "Post data is not a dictionary"
elif post_data.get("error"):
reason = "Post data contains an error"
elif not post_data.get("data"):
reason = "Post data missing 'data' key"
elif not post_data.get("data").get("post"):
reason = "Post data missing 'data.post' key"
if reason is None:
break
except Exception as e:
logger.error(f"Attempt {attempt + 1} failed with exception: {e}")
continue
if not post_data:
reason = "No post data returned"
elif not isinstance(post_data, dict):
reason = "Post data is not a dictionary"
elif post_data.get("error"):
reason = "Post data contains an error"
elif not post_data.get("data"):
reason = "Post data missing 'data' key"
elif not post_data.get("data").get("post"):
reason = "Post data missing 'data.post' key"
if reason is None:
break
logger.info(f"Retrying in {2 ** attempt} seconds...")
await asyncio.sleep(2 ** attempt)
attempt += 1
finally:
logger.info(f"Retrying in {2 ** attempt} seconds...")
await asyncio.sleep(2 ** attempt)
attempt += 1
else:
if not reason:
reason = "Unknown"