Is there a way to update the state of a task?

[danielmichalichyn]

In Celery Python we have the method to update the state of a task, like below:

def task(self):
    try:
        raise ValueError('Some error')
    except Exception as ex:
        self.update_state(state=states.FAILURE, meta={'custom': '...'})
        raise Ignore()

Is there any equivalent method in Celery Node?
My goal is to update the state of the task to FAILURE in case an error occurs in my worker.

[danielmichalichyn]

I've found out that when we throw an Error from the celery.node worker, the state of the Task is saved as 'SUCCESS'. This is because the state of the task is hard coded inside the taskHandler, when we call storeResult.
Maybe we can implement a CATCH in the taskPromise, so when a error is thrown from our worker, we can store the result as 'FAILURE'?
This is something that is suitable for the celery.node project, if yes, i can make a PR for this.

[actumn]

Hi. Thank you for reporting the issue.
You're right. It would be greatly appreciated if you make a PR.

Thank you.

[danielmichalichyn]

I've submitted a PR in order to solve this, i'm closing this issue.