added removing repo version of blacklisted packages to housekeeping

This commit is contained in:
2022-08-16 16:56:33 +02:00
parent ba8d02927f
commit b0d570363f

View File

@@ -650,11 +650,18 @@ func housekeeping(repo string, march string, wg *sync.WaitGroup) error {
if err != nil { if err != nil {
return err return err
} }
} else if dbPkg.Status == dbpackage.StatusSkipped && dbPkg.RepoVersion != "" && strings.HasPrefix(dbPkg.SkipReason, "blacklisted") {
log.Infof("[HK] delete blacklisted package %s", dbPkg.Pkgbase)
pkg := &ProtoPackage{
FullRepo: fullRepo,
March: march,
DbPackage: dbPkg,
}
buildManager.repoPurge[fullRepo] <- []*ProtoPackage{pkg}
} }
} }
/* // check packages for eligibility
// check queued packages for eligibility
log.Debugf("[HK/%s] check queued packages", fullRepo) log.Debugf("[HK/%s] check queued packages", fullRepo)
qPackages, err := db.DbPackage.Query().Where( qPackages, err := db.DbPackage.Query().Where(
dbpackage.And( dbpackage.And(
@@ -689,7 +696,6 @@ func housekeeping(repo string, march string, wg *sync.WaitGroup) error {
log.Warningf("[HK/%s] unable to determine status for %s: %v", fullRepo, dbPkg.Pkgbase, err) log.Warningf("[HK/%s] unable to determine status for %s: %v", fullRepo, dbPkg.Pkgbase, err)
} }
} }
*/
log.Debugf("[HK/%s] all tasks finished", fullRepo) log.Debugf("[HK/%s] all tasks finished", fullRepo)
return nil return nil