diff --git a/hypermap/aggregator/__init__.py b/hypermap/aggregator/__init__.py
index <HASH>..<HASH> 100644
--- a/hypermap/aggregator/__init__.py
+++ b/hypermap/aggregator/__init__.py
@@ -1,5 +0,0 @@
-from __future__ import absolute_import
-
-# This will make sure the app is always imported when
-# Django starts so that shared_task will use this app.
-from hypermap.celery import app as celery_app  # noqa
diff --git a/hypermap/aggregator/views.py b/hypermap/aggregator/views.py
index <HASH>..<HASH> 100644
--- a/hypermap/aggregator/views.py
+++ b/hypermap/aggregator/views.py
@@ -14,7 +14,7 @@ from tasks import (check_all_services, check_service, check_layer, remove_servic
                    index_service, index_all_layers, index_layer)
 from enums import SERVICE_TYPES
 
-import celery as celery_app
+from hypermap import celery_app
 
 
 def serialize_checks(check_set):
Importing celery the correct way