diff --git a/celery_haystack/tasks.py b/celery_haystack/tasks.py
index e2a1ce0d6ece4e5480517482b1b90d9643edfb32..ccfb67b69cc31d0bdab37073c83ee659c001454c 100644
--- a/celery_haystack/tasks.py
+++ b/celery_haystack/tasks.py
@@ -7,7 +7,7 @@ from .conf import settings
 from haystack import connections, connection_router
 from haystack.exceptions import NotHandled as IndexNotFoundException
 
-from celery.task import Task  # noqa
+from celery import Task  # noqa
 from celery.utils.log import get_task_logger
 
 logger = get_task_logger(__name__)