如何移除Celery任务返回的None或设置正确的任务状态？

• 任务始终显示succeeded状态：Celery默认只有在任务抛出未被捕获的异常时，才会将任务标记为FAILED状态。如果你的任务代码内通过try-except捕获了所有异常且未重新抛出，哪怕业务逻辑实际执行失败，Celery也会判定任务执行成功。
• 日志结尾显示None：Celery任务成功日志默认会打印任务的返回值，若任务执行过程中没有显式return任何内容，就会输出默认的None。

修正任务状态判定 #

如果需要执行出错的任务标记为失败，在异常处理逻辑完成后重新抛出异常即可，也可手动指定任务状态，示例代码如下：

from celery import Celery, states

app = Celery('Todos', broker='你的Broker地址')

@app.task(bind=True)
def launchalert(self):
    try:
        # 你的业务逻辑代码
        business_result = do_business_operation()
        # 正常执行完成后显式返回需要打印的内容，替换默认的None
        return f"执行成功，结果：{business_result}"
    except Exception as e:
        # 自定义异常处理逻辑，例如本地日志记录、告警通知等
        print(f"任务执行异常：{str(e)}")
        # 方案1：直接重新抛出异常，Celery会自动标记任务为FAILED
        raise
        # 方案2：手动设置任务状态和错误信息，适合需要自定义失败元数据的场景
        # self.update_state(state=states.FAILURE, meta={"error": str(e)})
        # raise

调整返回值日志展示 #

按你的需求二选一即可：

• 输出自定义日志内容：任务正常执行完成后显式return你需要展示的内容，日志会自动替换原有的None。
• 完全移除返回值展示：给对应任务添加ignore_result=True参数，或者全局配置Celery参数CELERY_IGNORE_RESULT = True，这样Celery不会存储和打印任务返回结果，日志结尾的返回值部分会直接消失。

如果修改后问题仍存在，可检查是否有自定义的Celery中间件、信号处理函数修改了任务状态或者覆盖了返回值。

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