This repository has been archived on 2020-03-24. You can view files and clone it, but cannot push or open issues or pull requests.
quay/workers/gc/gcworker.py
2017-06-29 09:37:32 +03:00

19 lines
663 B
Python

from app import app
from data.database import UseThenDisconnect
from workers.gc.models_pre_oci import pre_oci_model as model
from workers.worker import Worker
class GarbageCollectionWorker(Worker):
def __init__(self):
super(GarbageCollectionWorker, self).__init__()
self.add_operation(self._garbage_collection_repos,
app.config.get('GARBAGE_COLLECTION_FREQUENCY', 30))
def _garbage_collection_repos(self):
""" Performs garbage collection on repositories. """
with UseThenDisconnect(app.config):
model.perform_garbage_collection()
if __name__ == "__main__":
worker = GarbageCollectionWorker()
worker.start()