Imp fix

Update asap

Signed-off-by: Dawn India <[email protected]>

bot/helper/ext_utils/bot_utils.py

@@ -31,7 +31,16 @@
 from ..telegram_helper.bot_commands import BotCommands
 
 COMMAND_USAGE = {}
-THREAD_POOL = ThreadPoolExecutor(max_workers=4000)
+
+max_workers = min(
+    10000,
+    (
+        cpu_count()
+        or 0
+    ) + 4
+)
+THREAD_POOL = ThreadPoolExecutor(max_workers=max_workers)
+
 
 class SetInterval:
     def __init__(

bot/helper/listeners/task_listener.py

@@ -720,7 +720,7 @@ async def on_download_error(self, error, button=None):
             if self.mid in task_dict:
                 del task_dict[self.mid]
             count = len(task_dict)
-            await self.remove_from_same_dir()
+        await self.remove_from_same_dir()
         msg = f"Sorry {self.tag}!\nYour download has been stopped."
         msg += f"\n\n<code>Reason </code>: {escape(str(error))}"
         msg += f"\n<code>Past   </code>: {get_readable_time(time() - self.time)}"

bot/helper/telegram_helper/message_utils.py

@@ -1,7 +1,4 @@
-from asyncio import (
-    sleep,
-    create_task,
-)
+from asyncio import sleep
 from re import match as re_match
 from time import time
 from datetime import (
@@ -22,6 +19,7 @@
 from bot import (
     LOGGER,
     bot,
+    bot_loop,
     bot_name,
     cached_dict,
     config_dict,
@@ -141,7 +139,7 @@ async def auto_delete():
                 await delete_message(cmd_message)
             if bot_message is not None:
                 await delete_message(bot_message)
-        create_task(auto_delete())
+        bot_loop.create_task(auto_delete())
 
 
 async def delete_links(message):