Celery任务状态仅为“ PENDING”和“ SUCCESS”。为什么任务状态中没有“ STARTED”?

蓝犀牛

我正在演示,代码很简单:

# tasks.py
import time

from celery import Celery

app = Celery('tasks',
             broker='redis://:5tgb^YHN7ujm*IK<@localhost:6379/0',
             backend='redis://:5tgb^YHN7ujm*IK<@localhost:6379/0'
             )


@app.task
def test_task(s):
    time.sleep(300)
    return s

然后开始工作

 celery -A celery_test.app  worker -n kalidog -c 2 -l debug -E

 -------------- celery@kalidog v4.3.0 (rhubarb)
---- **** ----- 
--- * ***  * -- Linux-4.9.0-8-amd64-x86_64-with-debian-9.8 2019-10-11 02:36:12
-- * - **** --- 
- ** ---------- [config]
- ** ---------- .> app:         tasks:0x7f17bf92e128
- ** ---------- .> transport:   redis://:**@localhost:6379/0
- ** ---------- .> results:     redis://:**@localhost:6379/0
- *** --- * --- .> concurrency: 2 (prefork)
-- ******* ---- .> task events: ON
--- ***** ----- 
 -------------- [queues]
                .> celery           exchange=celery(direct) key=celery          

然后安排任务:

>>>from celery_test import test_task
>>>result = test_task.apply_async((11,)) 
>>>result.status
'PENDING'
>>>result.state
'PENDING'
>>>result.state
'PENDING'
>>>result.state
'SUCCESS'

为什么任务状态中没有“开始”?我检查了redis。在任务完成之前,redis中没有当前任务的密钥,例如“ celery-task-meta-XXX”。

德扬·莱基奇

默认情况下不启用该功能。此处的更多信息:https : //docs.celeryproject.org/en/latest/userguide/tasks.html#started

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章

定义多个任务时,如何获取某个Celery任务类型的任务状态和结果?

Python Celery任务的状态

Python Celery获取任务状态

如何在Celery中检查任务状态?

如何在Celery中检查任务状态?

为什么芹菜工人将任务置于PENDING状态这么长时间?

Django 和 Celery 任务

为什么“应用信息”和“清除任务”中没有出现“ Android应用图标”?

Celery + Django-使用Django消息框架进行状态和报告成功或失败的轮询任务

Django中的Celery任务始终处于阻塞状态

我在顶部和全部任务>睡眠+正在运行的任务中处于状态状态

为什么在合作取消中任务的状态是“故障”而不是“取消”?

返回什么任务,为什么该任务状态为RanToCompletion

如何更新特定任务的任务状态和实际值?

为什么有状态和无状态bean的行为相反?

使用 Django、celery 和 Redis 安排任务

如何按任务名称检查和取消Celery任务

远程工作者“ PENDING”的芹菜任务状态,但实际上是“成功”

为什么这个任务没有完成?

为什么状态在 vuex 中没有更新?

如何使用Django和Celery记录所有任务信息?

为什么我的 React 应用程序中的 console.logs 和 UI 没有显示相同的状态变量?

已卸载组件的状态更新。修复,取消 useEffect 清理函数中的所有订阅和异步任务

如何获取 celery 代理和后端的状态?

创建带有和不带有IO位图的正确的任务状态段(TSS)结构?

为什么状态没有改变?

为什么状态没有更新?

Kafka Streaming任务和内部状态存储的管理

为什么在有状态的小部件中需要didUpdateWidget和build方法?