diff --git a/utils/Sync/sync/core/SyncDocument.py b/utils/Sync/sync/core/SyncDocument.py index 90c641e6..704b493a 100644 --- a/utils/Sync/sync/core/SyncDocument.py +++ b/utils/Sync/sync/core/SyncDocument.py @@ -21,9 +21,7 @@ logger = logging.getLogger(settings.name + '.Document') class SyncDocument(Sync): def __init__(self, provider: Provider, collection, sizes): - super().__init__() - self.collection = collection - self.provider = provider + super().__init__(provider, collection) self.sizes = sizes self.dir_static_previews = '' @@ -32,7 +30,7 @@ class SyncDocument(Sync): async def clean(self): pass - async def run(self) -> ([Model], [Model]): + async def run(self): logger.info('Checking documents for update') documents = await Document.scan(self.provider) diff --git a/utils/Sync/sync/core/__init__.py b/utils/Sync/sync/core/__init__.py index b7f29b27..2df6a9d6 100644 --- a/utils/Sync/sync/core/__init__.py +++ b/utils/Sync/sync/core/__init__.py @@ -1,3 +1,4 @@ +from sync.data import Provider from sync.models import Model from utils.fn import lmap @@ -14,12 +15,13 @@ class Sync: def compile(document): return document.bake() - def __init__(self): + def __init__(self, provider: Provider, collection): super().__init__() - self.collection = None + self.provider = provider + self.collection = collection - async def run(self) -> ([Model], [Model]): + async def run(self): """ # Get scope files # Validate these files. Raise an error