Как обработать команду в телеграмм боте при работающем расписании на aioschedule?

Question

[DarkiDeuce]

Пишу парсер с выводом информации в телеграмм боте. Парс должен производиться каждые 20 минут. Для создания расписания использую aioschedule. Расписание работает корректно, но бот не реагирует на команды, то есть не срабатывает обработчик. Как сделать так, чтобы расписание было активно и бот обрабатывал команды?

Код с расписанием:

async def scheduler():
    aioschedule.every(20).minutes.do(analysis)

    while True:
        await aioschedule.run_pending()
        await asyncio.sleep(1)

async def on_startup(_):
    await asyncio.create_task(scheduler())

if __name__ == '__main__':
    executor.start_polling(dp, skip_updates=True, on_startup=on_startup)

Команда обрабатывается обычным хендлером:

@dp.message_handler(commands=['new'])
async def new(message: types.Message):
    await bot.send_message(message.chat.id, 'Текст сообщения')

Comments

[Александр]

DarkiDeuce
Как вариант запустить asyncio loop в функции on_startup, чтобы функция scheduler выполнялась в фоновом режиме, а телеграмм бот обрабатывал команды.

async def on_startup(dp):
    await bot.send_message(chat_id, "Bot is starting...")
    await asyncio.create_task(scheduler())
    await dp.loop.create_task(scheduler())

if __name__ == '__main__':
    executor.start_polling(dp, on_startup=on_startup)

Answer 1

[Vindicar]

await asyncio.create_task(scheduler())
Ты ждешь, пока scheduler() не закончит работу. Зачем? Вызов create_task() сам по себе планирует выполнение переданной корутины, её не имеет смысла awaitить - разве что только в плане "дождаться конца задачи".
Оставь просто вызов create_task(), без await, ну или сохрани возвращаемое create_task() значение в переменную (если нужно будет потом прервать выполнение scheduler()).

Comments

[DarkiDeuce]

Спасибо, друг. Теперь работает корректно. Всех благ тебе.