vvzvlad/pyrogram-bridge
1
0
Fork 0
Code Issues 6 Pull Requests Actions 8 Packages Projects Releases Wiki Activity

Refactor flood wait handling to return 429 status with Retry-After header instead of sleeping,

Browse Source
This commit is contained in:
vvzvlad
2025-03-22 14:28:12 +03:00
parent ac2c06fe22
commit 8723540389
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
api_server.py
+6 -4
View File
@@ -597,10 +597,12 @@ async def get_rss_feed(channel: str,
total_wait_time = wait_time + random_additional_wait
if total_wait_time > 190: total_wait_time = 190
logger.warning(f"flood_wait_error: channel {channel}, waiting {total_wait_time:.1f} seconds (base: {wait_time}s, random: {random_additional_wait:.1f}s)")
await asyncio.sleep(total_wait_time)
logger.info(f"flood_wait_retry: channel {channel}")
continue
logger.warning(f"flood_wait_error: channel {channel}, retry after {total_wait_time:.1f} seconds (base: {wait_time}s, random: {random_additional_wait:.1f}s)")
return Response(
status_code=429,
headers={"Retry-After": str(int(total_wait_time))},
content="Too many requests, please try again later"
)
except Exception as e:
error_message = f"rss_generation_error: channel {channel}, error {str(e)}"
logger.error(error_message)