@@ -4,7 +4,6 @@ Process Pools.
"""
import os
-import time
import errno
import multiprocessing
@@ -88,7 +87,7 @@ class DynamicPool(Pool):
if processes is None:
try:
- processes = cpu_count()
+ processes = multiprocessing.cpu_count()
except NotImplementedError:
processes = 1
@@ -1,6 +1,5 @@
"""celery.registry"""
from celery import discovery
-from celery.utils import get_full_cls_name
from celery.exceptions import NotRegistered, AlreadyRegistered
from UserDict import UserDict