import pprint from ..config import Telegram from pyrogram import Client if Telegram.SECONDARY: plugins = None no_updates = True else: plugins = dict(root="FileStream/bot/plugins") no_updates = None FileStream = Client(name="FileStream", api_id=Telegram.API_ID, api_hash=Telegram.API_HASH, workdir="FileStream", plugins=plugins, bot_token=Telegram.BOT_TOKEN, sleep_threshold=Telegram.SLEEP_THRESHOLD, workers=Telegram.WORKERS, no_updates=no_updates) WORK_LOADS = {} MULTI_CLIENTS = {} ACTIVE_CLIENTS = {} async def req_client(PUBLIC_IP:str)-> dict: index = min(WORK_LOADS, key=WORK_LOADS.get) faster_client = MULTI_CLIENTS[index] print("WorkLoads :",WORK_LOADS) return dict(index=index,public_ip=PUBLIC_IP, client=faster_client)