oklahomer
diff --git a/‎runner.go‎
Lines changed: 1 addition & 1 deletion b/‎runner.go‎
Lines changed: 1 addition & 1 deletion
@@ -222,7 +222,7 @@ func newRunner(ctx context.Context, config *Config) (*runner, error) {
 		workerConfig := worker.NewConfig()
 		workerConfig.WorkerNum = 100
 		workerConfig.QueueSize = 10
-		r.worker = worker.Run(ctx, worker.NewConfig())
+		r.worker = worker.Run(ctx, workerConfig)
 	}
 
 	return r, nil
Original file line number	Diff line number	Diff line change
`@@ -222,7 +222,7 @@ func newRunner(ctx context.Context, config Config) (runner, error) {`
`222`	`222`	`workerConfig := worker.NewConfig()`
`223`	`223`	`workerConfig.WorkerNum = 100`
`224`	`224`	`workerConfig.QueueSize = 10`
`225`		`- r.worker = worker.Run(ctx, worker.NewConfig())`
	`225`	`+ r.worker = worker.Run(ctx, workerConfig)`
`226`	`226`	`}`
`227`	`227`
`228`	`228`	`return r, nil`