xsteadfastx/workgroups
1
0
Fork 0
Code Issues Pull Requests Projects Releases 7 Wiki Activity

fix: removes own logger with caller
All checks were successful
continuous-integration/drone/push Build is passing
Details
continuous-integration/drone/tag Build is passing
Details

Browse Source
This commit is contained in:
Marvin Preuss 2022-01-13 13:02:18 +01:00
parent b1d12f53b0
commit bcf20fb800
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
workgroups.go
View File

@ -70,8 +70,8 @@ func NewDispatcher(ctx context.Context, numWorkers, workLength int) (*Dispatcher
// Start starts the configured number of workers and waits for jobs. // Start starts the configured number of workers and waits for jobs.
func (d *Dispatcher) Start() { func (d *Dispatcher) Start() {
for i := 0; i < d.numWorkers; i++ { for i := 0; i < d.numWorkers; i++ {
logger := log.With().Caller().Int("worker", i).Logger() logger := log.With().Int("worker", i).Logger()
logger.Info().Msg("starting worker") logger.Debug().Msg("starting worker")
d.eg.Go(func() error { d.eg.Go(func() error {
for j := range d.queue { for j := range d.queue {
@ -91,7 +91,7 @@ func (d *Dispatcher) Start() {
} }
} }
logger.Info().Msg("no work. returning...") logger.Debug().Msg("no work. returning...")
return nil return nil
}) })