浏览代码

Needs Kombu 1.0.8 or higher, or raise Exception. (1.0.7 could make pool acquire hang)

Ask Solem 14 年之前
父节点
当前提交
ea23438d78
共有 1 个文件被更改,包括 4 次插入0 次删除
  1. 4 0
      celery/app/base.py

+ 4 - 0
celery/app/base.py

@@ -21,6 +21,10 @@ from celery.datastructures import ConfigurationView
 from celery.utils import instantiate, lpmerge
 from celery.utils import instantiate, lpmerge
 from celery.utils.functional import wraps
 from celery.utils.functional import wraps
 
 
+import kombu
+if kombu.VERSION < (1, 0, 8):
+    raise ImportError("Celery requires Kombu version 1.0.8 or higher.")
+
 
 
 class LamportClock(object):
 class LamportClock(object):
     """Lamports logical clock.
     """Lamports logical clock.