芹菜正確傳播異常

Question

我有這個簡單的芹菜任務：

@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