Browse Source

Will now raise RuntimeError if a task attempts to join a subtask

Ask Solem 11 năm trước cách đây
mục cha
commit
b8f655adc1
1 tập tin đã thay đổi với 1 bổ sung1 xóa
  1. 1 1
      celery/result.py

+ 1 - 1
celery/result.py

@@ -36,7 +36,7 @@ See http://docs.celeryq.org/en/latest/userguide/tasks.html\
 
 def assert_will_not_block():
     if task_join_will_block():
-        pass   # TODO future version: raise
+        raise RuntimeError(E_WOULDBLOCK)
 
 
 class ResultBase(object):