|
@@ -91,8 +91,6 @@ from celery.worker.job import TaskRequest, InvalidTaskError
|
|
|
from celery.worker.control import ControlDispatch
|
|
|
from celery.worker.heartbeat import Heart
|
|
|
from celery.events import EventDispatcher
|
|
|
-from celery.messaging import establish_connection
|
|
|
-from celery.messaging import get_consumer_set, BroadcastConsumer
|
|
|
from celery.exceptions import NotRegistered
|
|
|
from celery.datastructures import SharedCounter
|
|
|
|