diff --git a/util/backfillreplication.py b/util/backfillreplication.py
index f13c61244..84a863ffc 100644
--- a/util/backfillreplication.py
+++ b/util/backfillreplication.py
@@ -1,8 +1,8 @@
 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()