Есть две функции flud_to_phantom, flud. Надо что бы они работали одновременно никак не получается настроить из-за самой асинхронной работы клиентов
async def flud_to_phantom(new_...):
if is_phantom:
global sessions
while True:
app = Client(name=account)
text = choice(messages)
async def ph_flud():
async with app:
await app.send_message(chat_id=new_chats[chat_n].id, text=text)
await app.stop()
app.run (ph_flud())
await asyncio.sleep(phantom_delay)
async def flud(accou...):
for account in account_list:
try:
app = Client(name=account)
async def connect_to_main():
async with app:
await app.join_chat(chat_id=chat_link)
await app.stop()
app.run(await connect_to_main())
except UserAlreadyParticipant:
print('акаунт уже в группе')
print('Успешно')
while True:
app_flud = Client(name=account)
text = choice(messages)
async def in_flud():
async with app_flud:
await app_flud.send_message(chat_id=chat.id, text=text)
await app_flud.stop()
app_flud.run(await in_flud())
acc_n = counter(acc_n, account_list)
await asyncio.sleep(delay)
Помогите настроить, а то я уже 5 час пробую
последнее что пытался это вызвать вот так(Подскажите что не так делаю, я пересмотрел уже 5 видосов, прочитал документацию но ничего не могу найти):
async def runner(new_ch...):
task_1 = asyncio.create_task(flud(accoun...))
task_2 = asyncio.create_task(flud_to_phantom(new_...))
await asyncio.gather(task_1, task_2)
Практически при всех попытках одна ошибка:
RuntimeWarning: Enable tracemalloc to get the object allocation traceback
Traceback (most recent call last):
File "C:\Users\....\main.py", line 275, in <module>
main()
File "C:\Users\....\main.py", line 263, in main
loop.run_until_complete(runner(new_ch...,
File "C:\Users\...\Python\Python310\lib\asyncio\base_events.py", line 646, in run_until_complete
return future.result()
File "C:\Users\...\main.py", line 216, in runner
await asyncio.gather(task_1, task_2)
File "C:\Users\...\main.py", line 98, in flud
asyncio.create_task(app.run(await connect_to_main()))
File "C:\Users\..venv\lib\site-packages\pyrogram\methods\utilities\run.py", line 85, in run
run(idle())
File "C:\Users\..Python\Python310\lib\asyncio\base_events.py", line 622, in run_until_complete
self._check_running()
File "C:\Use...\Python310\lib\asyncio\base_events.py", line 582, in _check_running
raise RuntimeError('This event loop is already running')
RuntimeError: This event loop is already running
sys:1: RuntimeWarning: coroutine 'idle' was never awaited
Process finished with exit code 1