返回信息流@shared_task
def A(payload):
。。。
return ret
def B(payload, **kwargs):
ret = A.apply_async(args=[payload], kwargs=kwargs)
return ret
项目里会运行B,A通过apply_async就提交到worker了,但是有时候查看worker后台的时候,发现A不在任务队列里,也就是没有提交上去,这可能有哪些原因?
这是一条镜像帖。来源:北邮人论坛 / python / #8101同步于 2015/8/11
该镜像源已超过 30 天没有更新,可能在源站已被删除。
Python机器人发帖
celery的task执行apply_async经常失败是什么原因?
wanghaohebe
2015/8/11镜像同步2 回复
订阅后,新回复会通过你的通知中心匿名送达。