Pass customized workerConfig instead of a fresh default one

oklahomer · oklahomer · commit dcf3f78e8c16 · 2026-02-07T10:45:37.000+09:00
diff --git a/runner.go b/runner.go
@@ -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`