Отмена coroutines на повторное нажатие кнопки?

Question

[roomONmoon]

Как я мог бы отменить уже выполняющиеся задачи, при повторном нажатии на кнопку?

Код который я набросал, но он конечно же не работает

class TasksManager:
    def __init__(self) -> None:
        self.state = False
        self.lst = [self.task_1, self.task_2, self.task_3]
 
    async def task_1(self):
        for i in range(10):
            await asyncio.sleep(1)
            print("Task 1: ", i)
    
    async def task_2(self):
        for i in range(10):
            await asyncio.sleep(1)
            print("Task 2: ", i)
 
    async def task_3(self):
        for i in range(10):
            await asyncio.sleep(1)
            print("Task 3: ", i)
 
    async def click(self, e: ft.TapEvent):
        if not self.state:
            self.state = True
            lst = [asyncio.create_task(task()) for task in self.lst]
            done, pending = await asyncio.wait(lst, return_when=asyncio.FIRST_COMPLETED)
            print(done, pending)
        else:
            # здесь нужно отменить корутины
            for task in pending:
                task.cancel()
 
def main(page: ft.Page):
    manager = TasksManager()
    button = ft.TextButton("Click", on_click=manager.click)
    page.add(button)
    page.update()
 
ft.app(main)

Answer 1

[Everything_is_bad]

1. ну так pending в else у тебя не определен, минимум стоит сделать его полем объекта
2. list это имя встроенного объекта, зачем ты его переопределяешь?
3. всегда показывай какие ошибки в твоем коде возникли

Comments

[roomONmoon]

1. ну так pending в else у тебя не определен, минимум стоит сделать его полем объекта

Вот в этом и вопрос, я не понимаю как и где мне нужно создать объект asyncio.wait, чтобы я всегда мог иметь к нему доступ.

2. list это имя встроенного объекта, зачем ты его переопределяешь?

Это по запарке, писал код на скорую руку чисто для примера сюда

3. всегда показывай какие ошибки в твоем коде возникли

Пока что ошибка в переменной pending, а точнее в её отсутствии

[Everything_is_bad]

roomONmoon, ну так 3 следствие 1, я тебе явно написал что делать, pending у тебя определен только внутри блока с if, как сделать его доступным это основы python, я тебе даже предложил "стоит сделать его полем объекта"

[roomONmoon]

Everything_is_bad, вы предлагаете сделать pending полем объекта manager?

[Everything_is_bad]

roomONmoon, ну а как ты еще можешь получить к нему доступ в else?

[roomONmoon]

Everything_is_bad,

self.done, self.pending = await asyncio.wait(list, return_when=asyncio.FIRST_COMPLETED)

вы об этом?

[Everything_is_bad]

roomONmoon, зачем переспрашивать каждую мелочь, сделал, проверь. done тебе далее нужно? если нет, зачем ты его полем сделал?

[roomONmoon]

Everything_is_bad, это не работает

File "/home/admin/Development/i10n/main.py", line 32, in click
    for task in self.pending:
TypeError: 'NoneType' object is not iterable

[Everything_is_bad]

roomONmoon, т.е. тебе еще и объяснять основы python?

[roomONmoon]

Everything_is_bad, нет, вы можете просто прислать пример вашей идеи, я буду благодарен

[Everything_is_bad]

roomONmoon, None значит нет у тебя pending задач, сделай на это проверку

[roomONmoon]

Everything_is_bad, в self.pending никогда нет задач, проверка здесь не нужна. Забавно, я предположил, что мои переменные обновляются только когда хотя бы одна задача была завершена, так оно и оказалось, я увеличил немного задержку выполнения задач и теперь задачи могут быть отменены

[roomONmoon]

roomONmoon, но это всё ещё не решает мой вопрос, что если мне нужно оборвать все задачи и мне не нужно ждать, пока хотя бы одна завершит своё выполнение и вернёт актуальные данные

[Everything_is_bad]

roomONmoon, так потому что у тебя задачи одинаковые по времени, ты ждешь выполнение первой задачи, но все остальные тоже будут выполнены

[Everything_is_bad]

roomONmoon,

мне нужно оборвать все задачи и мне не нужно ждать, пока хотя бы одна завершит своё выполнение

ну так зачем ты тогда используешь asyncio.wait? у тебе уже есть список задач, ты зачем-то еще захотел ожидать чтобы какая-то из них выполнилась

[roomONmoon]

Everything_is_bad, есть предположения как бы я мог оборвать задачи не дожидаясь завершения хотя бы одной?

[Everything_is_bad]

roomONmoon, ну так и не жди, у тебя уже есть список задач

[roomONmoon]

Everything_is_bad, Спасибо!