def log_error(task_id):
    result = celery.AsyncResult(task_id)
result.get(propagate=False)
with open(os.path.join('/var/errors', task_id), 'a') as fh:
    fh.write('--\n\n%s %s %s' % (task_id, result.result, result.traceback))
Сельдерей останавливает выполнение цепочки