fix: Not building on hf problem fixed.4

app.py

@@ -1,26 +1,15 @@
-from fastapi import FastAPI
-import logging
-
+import asyncio
 from bot_telegram import init_bot
 
-app = FastAPI()
-bot = None
-
-@app.on_event("startup")
-async def startup_event():
-    """Start the Telegram bot when the FastAPI application starts."""
-    global bot
+async def main():
     bot = init_bot()
-    await bot.run()
-
-@app.on_event("shutdown")
-async def shutdown_event():
-    """Stop the Telegram bot when the FastAPI application stops."""
-    global bot
-    if bot:
-        logging.info("Stopping bot...")
-        await bot.bot_stop()
-
-@app.get("/")
-def greet_json():
-    return {"Hello": "World!"}
+    try:
+        await bot.run()
+        # Keep the bot running
+        while True:
+            await asyncio.sleep(1)
+    except Exception as e:
+        print(f"Bot error: {e}")
+
+if __name__ == "__main__":
+    asyncio.run(main())

bot_telegram.py

@@ -45,9 +45,10 @@ class TelegramBot:
         self.ai_url = f"{self.base_url}/api/v1/questions/text"
         self.excel_url = f"{self.base_url}/api/v1/questions/excel"
 
-        # Separate executors for text and Excel
+        # Executors (keep only one instance of each)
         self.text_executor = ThreadPoolExecutor(max_workers=25, thread_name_prefix="text_worker")
         self.excel_executor = ThreadPoolExecutor(max_workers=20, thread_name_prefix="excel_worker")
+        self.excel_semaphore = asyncio.Semaphore(10)
         
         # Track active processes
         self.active_requests = {}
@@ -184,36 +185,34 @@ class TelegramBot:
     def _make_api_request(self, user_message):
         """Make API request"""
         try:
-            hf_authorization = "Bearer " + HF_TOKEN
             headers = {
-                "Authorization": hf_authorization,
+                "Authorization": f"Bearer {HF_TOKEN}",
                 "accept": "application/json"
             }
 
             json_payload = {"question": user_message}
             form_payload = {"question": user_message}
 
-            try:
+            response = requests.post(
+                self.ai_url, 
+                headers={**headers, "Content-Type": "application/json"}, 
+                json=json_payload
+            )
+
+            if response.status_code == 422:
                 response = requests.post(
                     self.ai_url, 
-                    headers={**headers, "Content-Type": "application/json"}, 
-                    json=json_payload
+                    headers={**headers, "Content-Type": "application/x-www-form-urlencoded"},
+                    data=form_payload
                 )
 
-                if response.status_code == 422:
-                    response = requests.post(
-                        self.ai_url, 
-                        headers={**headers, "Content-Type": "application/x-www-form-urlencoded"},
-                        data=form_payload
-                    )
-
-                if response.status_code == 200:
-                    return response.json().get("answer", "I didn't understand that.")
-                else:
-                    return f"Error: {response.status_code}"
+            if response.status_code == 200:
+                return response.json().get("answer", "I didn't understand that.")
+            else:
+                return f"Error: {response.status_code}"
 
-            except Exception as e:
-                return f"Connection error: {e}"
+        except Exception as e:
+            return f"Connection error: {e}"
 
     async def handle_excel(self, update: Update, context: CallbackContext):
         """Handle Excel files concurrently"""