celery - 如何让所有待处理的任务显示在芹菜花任务视图中?
问题描述
我目前正在运行带有花 1.0.0 的 celery 5,redis 作为代理和后端。
只有处于最终结果/墓碑状态的任务在花中可见。我需要启用其他配置更改吗?
celery -A main worker --hostname=annotate_@%h --pool=solo --task-events
flower -> flower:1.0.0 tornado:6.1 humanize:3.10.0
software -> celery:5.1.0 (sun-harmonics) kombu:5.1.0 py:3.10.0b1
billiard:3.6.4.0 py-amqp:5.0.6
platform -> system:Linux arch:64bit, ELF
kernel version:5.4.0-1051-azure imp:CPython
loader -> celery.loaders.app.AppLoader
settings -> transport:amqp results:disabled
deprecated_settings: None
worker configuration:
app = Celery(broker='redacted',
backend='redis://redacted'
)
app.autodiscover_tasks()
app.conf.task_default_queue = 'redacted'
app.conf.task_track_started = True
app.conf.task_send_sent_event = True
app.conf.worker_send_task_events = True
app.conf.worker_hijack_root_logger = False
app.conf.worker_prefetch_multiplier = 1
app.conf.worker_enable_remote_control = True
app.conf.result_expires = 60 * 60 * 2 # 2 hour TTL in seconds
以下是一些已完成任务的快照,但队列本身有 10 多个待处理和“正在进行”。
解决方案
推荐阅读
- vue.js - 如何在 Quasar Framework 中通过分页获取下一个数据?
- sql - SQL 脚本需要改进,可以使用一些技巧
- kubernetes - Helm 图表 - 沿静态值将数组设置为 tls.hosts
- sql-server - 如何在sql server中正确使用FOR XML函数以加快数据提取
- reactjs - 我已经开始做出反应,但是当我输入 npm start 时,它会给出这些错误消息
- python - 通过 API 创建的事件在 Google 日历应用上不可见
- python - tkinter 用户不可关闭的窗口
- java - 为什么 Hibernate 忽略非空约束?
- python - 如何循环通过多个多项式拟合改变度数
- python - 使用 python pyspark 在 Kafka 到 Spark 流数据管道的问题