Как отслеживать текущие задачи и не допускать дублирования задач? ⇐ Python

[Anonymous]

У меня есть скрипт Python, который получает входящие сообщения из Интернета и обрабатывает данные:

Код: Выделить всё

async with asyncio.TaskGroup() as task_group:
processor_task = task_group.create_task(processor.start(message), name=f"process_message_{message.sender_id}_task"

Я добавил имена для задач с интерполяцией f-строки, чтобы при отладке я знал, какая задача что и для кого делает.
Каждая итерация обработка сообщения может занять до часа.
Я хочу обрабатывать только одно сообщение от отправителя за раз, однако отправители иногда отправляют несколько сообщений.
Как я могу удалять дальнейшие сообщения от того же sender_id до тех пор, пока не будет для них не выполняется задача?
Как я могу проверить все запущенные задачи на одно и то же имя перед созданием задачи в TaskGroup?
Я попробовал прочитать документацию TaskGroup, но я не нашел ничего связанного.

Подробнее здесь: https://stackoverflow.com/questions/793 ... cate-tasks