diff --git a/pillar/manage.py b/pillar/manage.py
index 4409458e..a4fb353e 100755
--- a/pillar/manage.py
+++ b/pillar/manage.py
@@ -487,7 +487,7 @@ def subscribe_node_owners():
     """Automatically subscribe node owners to notifications for items created
     in the past.
     """
-    from application import after_inserting_nodes
+    from application.modules.nodes import after_inserting_nodes
     nodes_collection = app.data.driver.db['nodes']
     for n in nodes_collection.find():
         if 'parent' in n: