Worker on cancelled don't stop running

[DustGalaxy]

I have a worker that sometimes needs to be aborted by clicking a button, when I call the cancel_all() method, it does cancel, which I know from on_worker_state_changed. But the problem is that the operations that the running worker performed are not canceled. To give an example, we can take a for loop that will continue looping the sequence after calling cancel_all().

@work(name="my_worker_1", exclusive=True, thread=True)
async def my_worker(self) -> None:
    log: Log = self.query_one("#log")

    for i in range(10):
        time.sleep(0.5)
        log.write_line(str(i))


@on(Button.Pressed, "#stop_work")
def app_exit(self, event: Button.Pressed) -> None:
    self.app.workers.canсel_all()

I may have misunderstood or done something wrong. In this case, I would be grateful if you could point out the errors and how this situation can be resolved.

[github-actions[bot]]

We found the following entries in the FAQ which you may find helpful:

• How do I center a widget in a screen?
• Why do some key combinations never make it to my app?

Feel free to close this issue if you found an answer in the FAQ. Otherwise, please give us a little time to review.

This is an automated reply, generated by FAQtory

[willmcgugan]

Threads cannot be forcibly cancelled. Your threaded code needs to periodically check if it has been cancelled, and return if it is. Have a look a the example in the guide for how to do that...