Как исправить эту ошибку?

Question

[lemonlimelike]

Всем привет! Появилась такая ошибка:

/home/home/.local/lib/python3.6/site-packages/telebot/util.py:60: RuntimeWarning: coroutine 'take_message' was never awaited
  task(*args, **kwargs)

Как исправить?

Вот код:

# -*- coding: utf-8 -*-
import telebot
import asyncio

from telegram_client import TelegramSession as ts

api_id = ********************** # этот id вы получаете при создание приложения
api_hash = '***********************' # и этот тоже
username = '***************' # ваше имя в тг
id_channel = -***************** # id вашего канала
token = '********************' # токен вашего бота

bot = telebot.TeleBot(token)
client = ts(api_id,api_hash,username)

@bot.message_handler(content_types=['text'])
async def take_message(message):
	if '@' in message.text and ',' in message.text:
		channels = message.text.split(',')
		my_channel = channels[-1]
		parse_channel = channels[0:-1]
		await client.add_task(parse_channel,my_channel)
	else:
		return bot.send_message(message.chat.id,'<b>Проверьте правильность ввода!</b>',parse_mode='html')

if __name__ == '__main__':
	bot.polling(none_stop=True)

А это код модуля telegram_client:

from telethon import TelegramClient,sync,events,utils
import asyncio

class TelegramSession:
	def __init__(self,api_id,api_hash,username):
		self.__loop = asyncio.new_event_loop()
		asyncio.set_event_loop(self.__loop)
		self.client = TelegramClient(username, api_id, api_hash,loop=self.__loop)
		self.client.start()

	async def handler_channel(self,parse_channel,my_channel):
		#print(parse_channel)
		@self.client.on(events.NewMessage(chats=parse_channel))
		async def normal_handler(event):
			await self.client.send_message(my_channel,event.message)

	async def list_tasks(self):
		pass

	async def add_task(self,parse_channel,my_channel):
		print(parse_channel)
		await self.__loop.create_task(self.handler_channel(parse_channel,my_channel))

	async def stop_task(self,something):
		pass

	def run_until(self):
		self.client.run_until_disconnected()

Comments

[Алан Гибизов]

Я бы рекомендовал более полный лог прикладывать. А то понятно только, что 60 строка модуля util вашей библиотеки telethon споткнулась. А что именно к этому привело - нужно в логах смотреть.

[lemonlimelike]

Алан Гибизов, Так, только эта строка и показывается) серьезно)

Answer 1

[soremix]

Для асинхронной работы нужно использовать
telebot.AsyncTeleBot()
вместо
telebot.TeleBot()

И async не нужен перед функцией, если не ошибаюсь

Comments

[lemonlimelike]

Вот, я убрал async/await из функции:

@bot.message_handler(content_types=['text'])
def take_message(message):
	if '@' in message.text and ',' in message.text:
		channels = message.text.split(',')
		my_channel = channels[-1]
		parse_channel = channels[0:-1]
		print('MEssage')
		client.add_task(parse_channel,my_channel)
	else:
		return bot.send_message(message.chat.id,'<b>Проверьте правильность ввода!</b>',parse_mode='html')

Добавил print('message')
И вот что выводится

[Константин]

async нужен, если вы работаете асинхронно, тоесть у `client.add_task` должен быть `await`

[Константин]

https://habr.com/ru/post/421625/