Stopping celery task

[snakesonabrain]

Hi, first of all congratulations on your great effort to write this.

I updated the code to reflect a use case where an exception is raised during task execution but I want to handle it and then show a failure in the progress bar.

To do this, I added a method stop_task to ProgressRecorder which is then called as follows:

from celery.exceptions import Ignore

@shared_task(bind=True)
def test_task(self, delay=5, totaltime=10):
    progress_recorder = ProgressRecorder(self)
    try:
        for i in range(totaltime):
            time.sleep(delay)
            if i > 7:
                raise ValueError("Provoked an error")
            progress_recorder.set_progress(i + 1, totaltime)
        return 'done'
    except Exception as err:
        progress_recorder.stop_task(i + 1, 1, err)
        raise Ignore

By doing this, I fill up the progress bar to the maximum but then have a failed state for the task so that the error behaviour is triggered.

Let me know what you think about this tweak.

[CoryADavis]

I was wondering about this exact feature. Thanks for writing it, works great for what I needed.

[czue]

This is great, thanks. Sorry for my exceptional slowness! My notification settings prevented me from seeing it. 🙈

[czue]

Just released 0.0.5 which adds this. Thanks!