Celery中update_state更新任务失败状态不生效问题

核心原因是你在except块中捕获异常后，没有将异常重新抛出，直接吞掉了错误：

1. 你手动调用update_state写入FAILURE状态时，确实会先在TaskResult表生成对应状态的记录
2. 但因为异常被捕获，任务函数会继续执行直到正常退出（没有显式return也会默认返回None），Celery会判定任务执行成功，自动将任务终态覆写为SUCCESS，把你之前手动更新的失败状态覆盖掉
3. 内置的states.FAILURE是Celery认定的任务异常终态，只有任务抛出未捕获的异常时，Celery才会保留这个状态，不会再写入SUCCESS状态。

根据你的业务需求二选一即可：

• 方案1：需要任务真正标记为失败（触发Celery默认的失败逻辑、错误日志、失败回调等）
  在update_state执行完成后，重新抛出捕获到的异常即可，参考代码：

  import traceback
  from celery import states
  
  try: 
      result = resource.import_data(imported_data, raise_errors=True)
  except Exception as e:
      self.update_state(
          state=states.FAILURE,
          meta={
              "exc_type": type(e).__name__,
              "exc_message": traceback.format_exc().split("\n"),
          },
      )
      # 关键：不要吞异常，直接抛出保留原始异常栈
      raise
  

• 方案2：不需要触发Celery的失败逻辑，只想自定义标记业务上的失败状态
  不要使用内置的states.FAILURE状态值，改用自定义的状态字符串，比如"DATA_IMPORT_FAILED"，这类自定义状态不会被Celery的终态SUCCESS覆盖，后续业务逻辑查询任务状态时自行识别该状态做对应处理即可。

额外配置提示：你在初始化Celery实例时直接传了result_backend="django-db"参数，后续又调用了config_from_object读取Django配置中CELERY_开头的项，如果你的Django settings里也配置了CELERY_RESULT_BACKEND，会覆盖初始化时传入的值，建议统一在一处配置避免不一致。

内容的提问来源于stack exchange，提问作者Prakhar Rathi