Flower任务元数据和结果仅对芹菜的定期任务可见

2024-05-17 16:09:30 发布

您现在位置:Python中文网/ 问答频道 /正文

我有一个问题,元数据和任务结果只有在通过芹菜的定期任务功能调用任务时才能在Flower中看到

我的代码

from task_queue.celery import app
from tasks.warehouse.warehouse_tasks import synchronize_all_warehouses


@app.on_after_finalize.connect
def setup_periodic_tasks(sender, **kwargs):
    sender.add_periodic_task(3600, synchronize_all_warehouses.s(), name="synchronize_all_warehouses")


# Start task immediately after deploy so you do not have to wait 1h for results
result = synchronize_all_warehouses.apply_async()

定期芹菜任务: enter image description here

同一个任务,称为via.apply_async() enter image description here

我试图研究如何保存任务结果,但找不到答案。 至于我为什么需要这个解决方案:我希望在部署时立即看到任务运行,而不是等到周期性任务启动,在我的情况下是在1小时之后

这些任务在Kubernetes集群上运行,但在本地设置中问题是相同的


Tags: fromimportapptasksynchronizeasyncallwarehouse