Skip to content

Commit b4bc445

Browse files
committed
fix new worker
1 parent fa51163 commit b4bc445

1 file changed

Lines changed: 8 additions & 0 deletions

File tree

model/worker.go

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,14 @@ func NewWorker(name string, maxConcurrency int) (*Worker, error) {
4242
}
4343

4444
func NewWorkerWithOptions(name string, maxConcurrency int, options *OnError) (*Worker, error) {
45+
if len(name) == 0 || len(name) > 100 {
46+
return nil, fmt.Errorf("name must have a length between 1 and 100")
47+
}
48+
49+
if maxConcurrency < 1 || maxConcurrency > 1000 {
50+
return nil, fmt.Errorf("maxConcurrency must be between 1 and 100")
51+
}
52+
4553
err := options.IsValid()
4654
if err != nil {
4755
return nil, fmt.Errorf("invalid options: %w", err)

0 commit comments

Comments
 (0)