diff --git a/celery_haystack/tasks.py b/celery_haystack/tasks.py
index d8acedd..a70e0c0 100644
--- a/celery_haystack/tasks.py
+++ b/celery_haystack/tasks.py
@@ -7,7 +7,7 @@
 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__)