Celery+Redis环境下visibility_timeout配置未生效问题求助

针对长任务每隔20分钟被重新入队的问题，结合Celery 5.3.6 + Redis的环境，可从以下方向逐一排查：

1. 检查任务是否存在独立超时配置 #

若任务通过装饰器单独指定了visibility_timeout，会直接覆盖全局配置。查看任务定义代码，确认是否存在类似逻辑：

@app.task(visibility_timeout=1200)  # 对应20分钟
def long_running_task():
    # 任务执行逻辑

如果有，将参数值修改为3600或直接移除该参数，让任务继承全局配置。

2. 确认Redis Broker的配置优先级 #

在Celery 5.x版本中，针对Redis Broker，仅broker_transport_options下的visibility_timeout会生效：

• 全局visibility_timeout属于过时配置，不会对Broker生效
• result_backend_transport_options中的配置仅作用于结果存储，和任务重入队逻辑无关

你已配置broker_transport_options": {"visibility_timeout": 3600}，可通过命令验证当前生效的配置：

celery inspect config --app=你的应用名称

在输出中定位broker_transport_options节点，确认visibility_timeout值是否为3600。

3. 排查Worker与Redis的心跳异常 #

任务未完成却被重入队，大概率是Redis判定Worker已失联。结合你配置的task_reject_on_worker_lost=True，当Worker与Redis的心跳中断时，Broker会触发任务回退队列。

调整相关配置： #

"broker_heartbeat": 30,  # 每30秒发送一次心跳包
"broker_heartbeat_checkrate": 2,  # 每2秒检查一次心跳状态

同时检查Redis服务器的timeout配置（redis.conf中的timeout参数），建议设置为0（永不主动断开）或大于任务最长运行时长的值。

4. 确认任务确认逻辑正确性 #

你已配置worker_prefetch_multiplier=1和task_acks_late=True，这部分逻辑是正确的，但需确保任务代码中没有手动调用task.ack()的逻辑——提前确认会导致Broker认为任务已完成，可能引发异常重入队。

5. 检查默认队列的单独配置 #

若默认队列（celery队列）通过其他方式（如手动声明、第三方工具）设置了独立的超时属性，会覆盖全局配置。可通过Redis命令查看队列属性：

redis-cli HGETALL "celery"

如果存在visibility_timeout相关键值，将其修改为3600即可。

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