Update app.py

app.py

@@ -20,6 +20,25 @@ import asyncio
 from telegram import Bot
 
 import os
+import requests
+from requests.adapters import HTTPAdapter
+from requests.packages.urllib3.util.retry import Retry
+
+
+def send_telegram_message(token, chat_id, message):
+    bot = Bot(token=token)
+    retries = Retry(total=5, backoff_factor=0.5, status_forcelist=[500, 502, 503, 504])
+    adapter = HTTPAdapter(max_retries=retries)
+    http = requests.Session()
+    http.mount("https://", adapter)
+    
+    try:
+        response = bot.send_message(chat_id=chat_id, text=message)
+        print("Message sent successfully:", response)
+    except telegram.error.TelegramError as e:
+        print(f"Failed to send message: {e}")
+
+
 
 def load_resolv_conf():
     with open('/etc/resolv.conf', 'r') as resolv_conf:
@@ -36,10 +55,6 @@ print(df_resume.head())
 model = SentenceTransformer("all-MiniLM-L6-v2")
 # file_name = 'questions.txt'
 
-async def send_telegram_message(token, chat_id, message):
-    bot = Bot(token=token)
-    await bot.send_message(chat_id=chat_id, text=message)
-    print("Message sent successfully.")
 
 
 def savevectorstore():
@@ -93,7 +108,7 @@ def rag_chain(question,name):
     # with open('questions.txt', 'a',encoding='utf-8') as file:
     #     file.write(f"\n\n{question}\n\n{country}\n\n{whatsapp}\n\n{name}||{sales}||{profit}||{product}")
     message = f"{name}\n\n{question}\n\n{ans}"
-    asyncio.run(send_telegram_message(token, chat_id, message))
+    send_telegram_message(token, chat_id, message)
     return que,ans
 # rag_chain('I am very hungry.')