diff --git a/util/backfillreplication.py b/util/backfillreplication.py
index f13c61244..e63cd45fe 100644
--- a/util/backfillreplication.py
+++ b/util/backfillreplication.py
@@ -1,16 +1,17 @@
 import logging
 import features
 
-from endpoints.replication import queue_storage_replication
 from data.database import Image, ImageStorage, Repository, User
+from util.registry.replication import queue_storage_replication
 
 def backfill_replication():
   encountered = set()
-  query = (Image.select(Image, ImageStorage, Repository, User)
-                .join(ImageStorage)
-                .switch(Image)
-                .join(Repository)
-                .join(User))
+  query = (Image
+           .select(Image, ImageStorage, Repository, User)
+           .join(ImageStorage)
+           .switch(Image)
+           .join(Repository)
+           .join(User))
 
   for image in query:
     if image.storage.uuid in encountered: