astra/plc-mirror
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Merge branch 'main' of github.com:uabluerail/indexer

Browse source
This commit is contained in:
mathan 2024-02-19 10:59:24 -08:00
commit 8b86f8f929
1 changed files with 4 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

6
cmd/record-indexer/scheduler.go
View file

@ -101,8 +101,10 @@ func (s *Scheduler) fillQueue(ctx context.Context) error {
if err := s.db.Find(&remotes).Error; err != nil {
return fmt.Errorf("failed to get the list of PDSs: %w", err)
}
perPDSLimit := maxQueueLen * 2 / len(remotes)
perPDSLimit := 0
if len(remotes) > 0 {
perPDSLimit = maxQueueLen * 2 / len(remotes)
}
for _, remote := range remotes {
repos := []repo.Repo{}