python - Celery 错误地传播异常

Question

我有这个简单的 celery 任务:

@celery.task
def test_exception():
    raise ValueError("foo")

我想使用 get如果我的任务恰好快速完成，则获取结果的方法。

但是，我得到的不是预期的内置 ValueError，而是 celery.backends.base.ValueError。在这种情况下，我怎样才能得到原始的 ValueError？

>>> from tasks import test_exception
>>> try:
...     test_exception.delay().get()
... except ValueError as e:
...     print("Success: %s", str(e))
... except:
...     E=sys.exc_info()
...
>>> E
(<class 'celery.backends.base.ValueError'>, ValueError(u'foo',), <traceback object at 0x7f858c7f5ea8>)
>>> E[0].__module__
'celery.backends.base'

Answer 1

针对此问题，他们的跟踪器中存在错误。它与 Celery 序列化异常有关，但无法可靠地反序列化它。

https://github.com/celery/celery/issues/3586

https://github.com/celery/celery/issues/3758

看来他们不会修复它。我提出的有点难看且完全糟糕的解决方法只是检查异常类的名称。

if e.__class__.__name__ == "MyUniquelyNamedException":
    ...
else:
    raise