celery 不适用于继承和属性装饰器

Question

我正在尝试对 celery 使用继承

这是我的课程：

class A(object):
  @property
  def var(self):
    return self._var

  @var.setter
  def var(self, value):
    self._var = value

  def b(self):
    self.var = 'b'

class B(A):
  @celeryapp.task(name='B.b', filter=task_method)
  def b(self):
    super(B, self).b()

这是我的主要代码：

# instanciate B
instb = B()
# Send a task to celery
instb.b.delay()

Celery 输出日志：

[2014-01-24 12:48:11,407: INFO/MainProcess] Received task: B.b[57833124-7691-443a-ad5a-d7caea4578d3]

到目前为止一切都很好，但是当我尝试获取 var 属性时

print instb.var()
# or
print instb.var

蟒蛇说：

AttributeError: 'B' object has no attribute '_var'

有人可以向我解释为什么它不起作用？ 谢谢

Answer 1

A 和B 都没有__init__ 方法，这意味着_var 属性在instance.b() 运行或instance.var（或直接分配instance._var）之前不存在。您可以初始化此属性以避免错误：

class A(object):
    def __init__(self):
        self._var = None

但是，更广泛的问题是您期望 b() 在您调用 print b.var 时已经运行（不应该是 instb.var 吗？）您需要获得任务的结果然后等待它完成：

result = instb.b.delay()
result.get()
print instb.var

请参阅AsyncResult 和calling tasks 上的文档。