From ebce8e01415c71d402bc476028aa28eecd7a0acc Mon Sep 17 00:00:00 2001 From: profitroll Date: Mon, 26 Jun 2023 13:06:23 +0200 Subject: [PATCH] Fixed workers and max_concurrent_transmissions --- libbot/pyrogram/classes/client.py | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/libbot/pyrogram/classes/client.py b/libbot/pyrogram/classes/client.py index a122ad1..cd0cf5b 100644 --- a/libbot/pyrogram/classes/client.py +++ b/libbot/pyrogram/classes/client.py @@ -1,6 +1,6 @@ import logging from datetime import datetime, timedelta -from os import getpid +from os import cpu_count, getpid from pathlib import Path from time import time from typing import List, Union @@ -54,12 +54,16 @@ class PyroClient(Client): bot_token=self.config["bot"]["bot_token"], # Workers should be commented when using convopyro, otherwise # handlers land in another event loop and you won't see them - workers=self.config["bot"]["workers"], + workers=self.config["bot"]["workers"] + if "workers" in self.config["bot"] + else min(32, cpu_count() + 4), plugins=dict(root="plugins", exclude=self.config["disabled_plugins"]), sleep_threshold=120, max_concurrent_transmissions=self.config["bot"][ "max_concurrent_transmissions" - ], + ] + if "max_concurrent_transmissions" in self.config["bot"] + else 1, ) self.owner: int = self.config["bot"]["owner"] self.commands: List[PyroCommand] = []