Adds task state cleanup for celery workers who restart unexpectedly