Do not continue if semaphore can't be acquired (#49)

trufflesecurity · Mar 4, 2022 · c742f6a · c742f6a
1 parent 30034f5
commit c742f6a
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/pkg/sources/github/github.go b/pkg/sources/github/github.go
@@ -293,7 +293,10 @@ func (s *Source) Chunks(ctx context.Context, chunksChan chan *sources.Chunk) err
 	errs := []error{}
 	var errsMut sync.Mutex
 	for i, repoURL := range s.repos {
-		s.jobSem.Acquire(ctx, 1)
+		if err := s.jobSem.Acquire(ctx, 1); err != nil {
+			log.WithError(err).Debug("could not acquire semaphore")
+			continue
+		}
 		wg.Add(1)
 		go func(ctx context.Context, repoURL string, i int) {
 			defer s.jobSem.Release(1)