asyncio_bot+worker

from config import test_token
API_TOKEN = test_token

import asyncio
from aiogram import Bot, Dispatcher, types
from aiogram.utils import executor

bot = Bot(token=API_TOKEN)
dp = Dispatcher(bot)

queue = asyncio.Queue(maxsize=100)


async def worker():
    while True:
        user_msg, video_status_msg = await queue.get()
        #обрабатываем инфу
        queue.task_done()


@dp.message_handler(content_types = ['text'])
async def process_message(message: types.Message):
    status_msg = await message.answer('Вы добавлены в очередь!')
    await queue.put([message, status_msg])


if __name__ == '__main__':
    asyncio.gather(worker(), executor.start_polling(dp, skip_updates=True))