Skip to content

Commit

Permalink
use max of 1 and x not min
Browse files Browse the repository at this point in the history
  • Loading branch information
mina1460 committed Jan 29, 2024
1 parent a1d33fa commit b1b1f68
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion internal/jimm/river.go
Original file line number Diff line number Diff line change
Expand Up @@ -146,7 +146,7 @@ func NewRiver(ctx context.Context, newRiverArgs NewRiverArgs) (*River, error) {
newRiverArgs.Config = &river.Config{
RetryPolicy: &river.DefaultClientRetryPolicy{},
Queues: map[string]river.QueueConfig{
river.QueueDefault: {MaxWorkers: min(1, newRiverArgs.MaxWorkers)},
river.QueueDefault: {MaxWorkers: max(1, newRiverArgs.MaxWorkers)},
},
// Logger: slog.Default(),
Workers: workers,
Expand Down

0 comments on commit b1b1f68

Please sign in to comment.