소스 검색

Billiard send_offset test cannot just check for _billiard

Ask Solem 11 년 전
부모
커밋
f27ecc574c
1개의 변경된 파일2개의 추가작업 그리고 2개의 파일을 삭제
  1. 2 2
      celery/concurrency/processes.py

+ 2 - 2
celery/concurrency/processes.py

@@ -453,8 +453,8 @@ class TaskPool(BasePool):
         """
         if self.options.get('maxtasksperchild'):
             try:
-                import _billiard  # noqa
-                _billiard.Connection.send_offset
+                from billiard import Connection
+                Connection.send_offset
             except (ImportError, AttributeError):
                 # billiard C extension not installed
                 warning(MAXTASKS_NO_BILLIARD)