tasks: added a periodic task for repo maintenance. Fixes #5202

rhodecode/lib/celerylib/tasks.py

@@ -279,6 +279,21 b' def sync_repo(*args, **kwargs):'
 
 
 @async_task(ignore_result=True)
+def repo_maintenance(repoid):
+    from rhodecode.lib import repo_maintenance as repo_maintenance_lib
+    log = get_logger(repo_maintenance)
+    repo = Repository.get_by_id_or_repo_name(repoid)
+    if repo:
+        maintenance = repo_maintenance_lib.RepoMaintenance()
+        tasks = maintenance.get_tasks_for_repo(repo)
+        log.debug('Executing %s tasks on repo `%s`', tasks, repoid)
+        executed_types = maintenance.execute(repo)
+        log.debug('Got execution results %s', executed_types)
+    else:
+        log.debug('Repo `%s` not found or without a clone_url', repoid)
+
+
+@async_task(ignore_result=True)
 def check_for_update():
     from rhodecode.model.update import UpdateModel
     update_url = UpdateModel().get_update_url()

rhodecode/model/db.py

@@ -1725,6 +1725,17 b' class Repository(Base, BaseModel):'
         return q.scalar()
 
     @classmethod
+    def get_by_id_or_repo_name(cls, repoid):
+        if isinstance(repoid, (int, long)):
+            try:
+                repo = cls.get(repoid)
+            except ValueError:
+                repo = None
+        else:
+            repo = cls.get_by_repo_name(repoid)
+        return repo
+
+    @classmethod
     def get_by_full_path(cls, repo_full_path):
         repo_name = repo_full_path.split(cls.base_path(), 1)[-1]
         repo_name = cls.normalize_repo_name(repo_name)