Skip to content
This repository was archived by the owner on Jun 2, 2023. It is now read-only.

Commit 20c9a0a

Browse files
author
Denis Isaev
committed
support PR_REANALYZER_REPO_ID_FILTER
1 parent 08c6b22 commit 20c9a0a

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

pkg/app/crons/pranalyzes/reanalyzer.go

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -95,8 +95,12 @@ func (r Reanalyzer) RunOnce() error {
9595
startedAt := time.Now()
9696
dur := r.cfg.GetDuration("PR_REANALYZER_DURATION", time.Hour*24*9)
9797
var analyzes []models.PullRequestAnalysis
98-
err := models.NewPullRequestAnalysisQuerySet(r.db).
99-
CreatedAtGte(time.Now().Add(-dur)).OrderDescByID().All(&analyzes)
98+
qs := models.NewPullRequestAnalysisQuerySet(r.db).CreatedAtGte(time.Now().Add(-dur)).OrderDescByID()
99+
if repoID := r.cfg.GetInt("PR_REANALYZER_REPO_ID_FILTER", 0); repoID != 0 {
100+
qs = qs.RepoIDEq(uint(repoID))
101+
}
102+
103+
err := qs.All(&analyzes)
100104
if err != nil {
101105
return errors.Wrapf(err, "failed to fetch last pr analyzes for %s", dur)
102106
}

0 commit comments

Comments
 (0)