AlekseyPython
никак не запускались
 asyncio.create_task(worker(f'worker-{i}', queue))
Этого достаточно.
AlekseyPython
Зачем какие- то кенселы посылать?
Потому что вокеры бесконечные. Если снова что-то напихать в очередь они опять будут работать.
Без остановки вокеров процесс тоже будет завершаться но будет ругаться на наличие незавершенных сопрограмм.