commit
12c7f20ae9
1 changed files with 7 additions and 6 deletions
|
@ -1,16 +1,17 @@
|
||||||
import logging
|
import logging
|
||||||
import features
|
import features
|
||||||
|
|
||||||
from endpoints.replication import queue_storage_replication
|
|
||||||
from data.database import Image, ImageStorage, Repository, User
|
from data.database import Image, ImageStorage, Repository, User
|
||||||
|
from util.registry.replication import queue_storage_replication
|
||||||
|
|
||||||
def backfill_replication():
|
def backfill_replication():
|
||||||
encountered = set()
|
encountered = set()
|
||||||
query = (Image.select(Image, ImageStorage, Repository, User)
|
query = (Image
|
||||||
.join(ImageStorage)
|
.select(Image, ImageStorage, Repository, User)
|
||||||
.switch(Image)
|
.join(ImageStorage)
|
||||||
.join(Repository)
|
.switch(Image)
|
||||||
.join(User))
|
.join(Repository)
|
||||||
|
.join(User))
|
||||||
|
|
||||||
for image in query:
|
for image in query:
|
||||||
if image.storage.uuid in encountered:
|
if image.storage.uuid in encountered:
|
||||||
|
|
Reference in a new issue