Dmitry Beresnev
commited on
Commit
·
f9f20cc
1
Parent(s):
ba18aad
fix 429 error for openrouter api
Browse files
src/telegram_bot/telegram_bot_service.py
CHANGED
|
@@ -1,3 +1,4 @@
|
|
|
|
|
| 1 |
from typing import Any
|
| 2 |
from datetime import datetime, timedelta
|
| 3 |
import time
|
|
@@ -265,6 +266,7 @@ class TelegramBotService:
|
|
| 265 |
elapsed = time.perf_counter() - start_time
|
| 266 |
main_logger.info(f"Processing time: {elapsed:.2f} seconds")
|
| 267 |
await self.send_message_via_proxy(chat_id, f"LLM Response for {news.get('headline', 'No headline')}: {response}")
|
|
|
|
| 268 |
|
| 269 |
async def news_feed_pooling_by_ticker(
|
| 270 |
self, ticker: str, chat_id: int, text: str | None, user_name: str
|
|
|
|
| 1 |
+
import asyncio
|
| 2 |
from typing import Any
|
| 3 |
from datetime import datetime, timedelta
|
| 4 |
import time
|
|
|
|
| 266 |
elapsed = time.perf_counter() - start_time
|
| 267 |
main_logger.info(f"Processing time: {elapsed:.2f} seconds")
|
| 268 |
await self.send_message_via_proxy(chat_id, f"LLM Response for {news.get('headline', 'No headline')}: {response}")
|
| 269 |
+
await asyncio.sleep(4) # Rate limit to avoid hitting Openrouter API limits
|
| 270 |
|
| 271 |
async def news_feed_pooling_by_ticker(
|
| 272 |
self, ticker: str, chat_id: int, text: str | None, user_name: str
|