Неправильная постановка задач для асинхронных функции

async def main(client):
    print(client)
    await client.connect()
    def select_rest(query):
        conn = pymysql.connect(host=new_base, user=user_base, password=password_base, db=db_rest, charset='utf8',
                               autocommit=True)
        cur = conn.cursor()
        cur.execute(query)
        cur.close()
        conn.close()
        resources = cur.fetchall()
        return resources
 
    result = select_rest("""SELECT res_id,link,owner_id
                               FROM res_updates RU
                               WHERE type=9 AND stability=1
                               ORDER BY start ASC LIMIT 1500 """)
 
    ch = []
    for item in result:
        ch.append(item[1])
    print('main')
    count = 0
    for item in ch:
        t = randint(10, 15)
        print(f'Время задержки {t} секунд!')
        sleep(t)
        count += 1
        try:
            channel = '@' + item[13:]
            print(channel)
        except:
            print('ошибка на стадии подготовки')
        try:
            await client(JoinChannelRequest(channel))
            print(f'{count} Подписка на {channel} прошла успешно')
        except Exception as ex:
            print(ex)
            return ex
 
 
 
with client:
    client.loop.run_until_complete(main(client))
    print('zzzz первый сон')
    sleep(60)
    client.loop.run_until_complete(main(client1))
    print('zzzz второй сон')
    sleep(60)
    client.loop.run_until_complete(main(client2))
    print('zzzz третий сон')
    sleep(60)