Update app.py

app.py

@@ -65,6 +65,10 @@ except RuntimeError:
     main_loop = asyncio.new_event_loop()
     asyncio.set_event_loop(main_loop)
 
+def run_async(coro):
+    future = asyncio.run_coroutine_threadsafe(coro, main_loop)
+    return future.result()
+
 bot = Client("file_unlocker_bot", api_id=API_ID, api_hash=API_HASH, bot_token=BOT_TOKEN)
 
 # ==================== ROBUST DB QUERY WITH AUTO-RETRY ====================
@@ -1196,7 +1200,7 @@ async def watermark_processor_loop():
         print(f"❌ Redis Connection Failed in Hugging Face: {e}")
         return
     
-    # সার্ভার রিস্টার্ট হলে আটকে থাকা লকগুলো ক্লিয়ার করবে
+    # Clear stuck locks
     try:
         async for key in redis_client.scan_iter("wm_processing:*"):
             await redis_client.delete(key)
@@ -1208,7 +1212,6 @@ async def watermark_processor_loop():
                 await asyncio.sleep(2)
                 continue 
             
-            # BRPOP এর বদলে RPOP ব্যবহার করা হলো (Upstash Connection Drop এড়াতে)
             result = await redis_client.rpop("watermark_task_queue")
             
             if result:
@@ -1219,7 +1222,7 @@ async def watermark_processor_loop():
                 processing_owners.add(owner_id)
                 asyncio.create_task(process_single_video(task, redis_client))
             else:
-                await asyncio.sleep(2) # ভিডিও না থাকলে ২ সেকেন্ড পর আবার চেক করবে
+                await asyncio.sleep(2)
                     
         except Exception as e:
             print(f"❌ [WM] Loop Error: {e}")
@@ -1243,4 +1246,5 @@ async def main():
 
 if __name__ == "__main__":
     threading.Thread(target=run_flask, daemon=True).start()
-    main_loop.run_until_complete(main())
+    main_loop.run_until_complete(main())
+#--- END OF FILE main.py