如何更新Celery任务状态，让Flower显示中间进度状态？

核心原因分析 #

你的代码逻辑本身没问题（状态能正常写入Redis），Flower不展示中间状态的核心问题通常是Celery Worker未发送状态事件，或者Flower未正确监听这些事件——Flower依赖Celery的事件总线来实时同步任务状态，而非直接读取Redis中的任务状态。

具体解决步骤 #

1. 确保Celery Worker开启事件发送 #

启动Worker时必须添加-E（或--events）参数，让Worker将所有状态变更（包括自定义的PROGRESS）发送到Celery事件总线：

celery -A your_project worker -Q my_queue -l info -E

没有这个参数，Worker只会把状态写入Redis，不会主动广播状态变更事件，Flower自然接收不到中间状态更新。

2. 检查Flower的启动配置 #

启动Flower时确保连接到正确的Celery实例，必要时指定Broker地址：

# 直接关联Celery应用
celery -A your_project flower --port=5555

# 或指定Redis Broker地址（分布式场景）
celery flower --broker=redis://localhost:6379/0 --port=5555

如果之前启动过Flower，建议重启清除缓存，避免旧状态干扰。

3. 验证Celery事件是否正常发送 #

用Celery自带的事件监听工具，确认PROGRESS状态事件是否被发送：

celery -A your_project events -l info

运行任务时，如果控制台输出包含task-state-update事件且状态为PROGRESS，说明事件发送正常；如果没有，回到第一步检查Worker启动参数。

4. 调整代码中的状态更新逻辑 #

• 避免在任务进入终端状态（SUCCESS/FAILURE）后再发送中间状态：你的代码中先设置PROGRESS再设置SUCCESS的顺序是对的，但注意self.update_state(state="SUCCESS")会提前标记任务为成功，后续的sleep不会影响状态，但不影响中间状态的发送。
• 无需单独异步任务更新状态：当前任务直接调用update_state是最优方式，单独任务会增加复杂度，且完全没必要。

5. 版本兼容性检查 #

确保Flower和Celery版本兼容，旧版Flower可能不支持自定义状态展示，尝试升级到最新版：

pip install --upgrade flower

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