为何Celery任务抛出错误却仍显示SUCCESS状态？

你的猜测完全正确——Celery标记任务为SUCCESS的核心逻辑是任务没有抛出未被捕获的异常。

看你的代码，所有异常都被try...except块捕获，并且你把异常转为字符串后return了。对Celery来说，这相当于任务“正常执行完成并返回了一个结果”，所以它会把celery_taskmeta里的状态设为SUCCESS，哪怕你的业务逻辑其实出了错。

解决方法 #

• 直接抛出异常（推荐）
  不要在except块里返回错误字符串，而是重新抛出异常，让Celery捕获到未处理的错误：

  except Exception as e:
      raise e
  

  这样Celery会自动将任务状态标记为FAILURE，同时日志里会完整保留错误信息。如果需要重试任务，还可以用self.retry(exc=e, countdown=60)替代raise e。

• 手动更新状态+抛出异常
  如果你既想返回错误详情，又要让任务状态显示为FAILURE，可以结合update_state方法：

  except Exception as e:
      error_msg = str(e)
      # 手动更新任务状态为FAILURE，并附加错误信息
      self.update_state(state='FAILURE', meta={'error': error_msg})
      # 必须抛出异常，否则Celery还是会标记为SUCCESS
      raise Exception(error_msg)
  

额外优化建议 #

你的文件操作部分可以改用with语句，它会自动帮你关闭文件，避免资源泄漏：

with open(full_file_path, 'w') as file:
    file.write(result)

内容的提问来源于stack exchange，提问作者Mạnh Đỗ Duy