Check that max_goroutines is at least min_goroutines (#28)

hermanschaaf · web-flow · commit 77238a9f86ff · 2022-08-31T16:20:43.000+02:00
diff --git a/plugins/source.go b/plugins/source.go
@@ -138,7 +138,7 @@ func (p *SourcePlugin) Sync(ctx context.Context, spec specs.Source, res chan<- *
 
 	// limiter used to limit the amount of resources fetched concurrently
 	maxGoroutines := spec.MaxGoRoutines
-	if maxGoroutines == 0 {
+	if maxGoroutines < minGoRoutines {
 		maxGoroutines = minGoRoutines
 	}
 	p.logger.Info().Uint64("max_goroutines", maxGoroutines).Msg("starting fetch")

Original file line number	Diff line number	Diff line change
`@@ -138,7 +138,7 @@ func (p SourcePlugin) Sync(ctx context.Context, spec specs.Source, res chan<- `
`138`	`138`
`139`	`139`	`// limiter used to limit the amount of resources fetched concurrently`
`140`	`140`	`maxGoroutines := spec.MaxGoRoutines`
`141`		`- if maxGoroutines == 0 {`
	`141`	`+ if maxGoroutines < minGoRoutines {`
`142`	`142`	`maxGoroutines = minGoRoutines`
`143`	`143`	`}`
`144`	`144`	`p.logger.Info().Uint64("max_goroutines", maxGoroutines).Msg("starting fetch")`