Skip to content
This repository was archived by the owner on Jan 15, 2022. It is now read-only.

Commit 5794659

Browse files
committed
ability to working in produce only mode
1 parent c5fbfe0 commit 5794659

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

config.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ func (c *Config) Hydrate(cfg service.Config) (err error) {
4040
return err
4141
}
4242

43-
if c.Workers.Pool != nil {
43+
if c.Workers.Command != "" {
4444
if err := c.Workers.Pool.Valid(); err != nil {
4545
return c.Workers.Pool.Valid()
4646
}

service.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ func (svc *Service) Init(
7676
}
7777

7878
// limit the number of parallel threads
79-
if svc.cfg.Workers.Pool != nil {
79+
if svc.cfg.Workers.Command != "" {
8080
svc.execPool = make(chan Handler, svc.cfg.Workers.Pool.NumWorkers)
8181
for i := int64(0); i < svc.cfg.Workers.Pool.NumWorkers; i++ {
8282
svc.execPool <- svc.exec

0 commit comments

Comments
 (0)