Skip to content

Commit f5e97c0

Browse files
committed
sweepbatcher: log batcher failures
This is useful to debug. It used to fail silently.
1 parent db5e0d1 commit f5e97c0

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

sweepbatcher/sweep_batcher.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -375,18 +375,22 @@ func (b *Batcher) Run(ctx context.Context) error {
375375
case sweepReq := <-b.sweepReqs:
376376
sweep, err := b.fetchSweep(runCtx, sweepReq)
377377
if err != nil {
378+
log.Warnf("fetchSweep failed: %v.", err)
378379
return err
379380
}
380381

381382
err = b.handleSweep(runCtx, sweep, sweepReq.Notifier)
382383
if err != nil {
384+
log.Warnf("handleSweep failed: %v.", err)
383385
return err
384386
}
385387

386388
case err := <-b.errChan:
389+
log.Warnf("Batcher received an error: %v.", err)
387390
return err
388391

389392
case <-runCtx.Done():
393+
log.Infof("Stopping Batcher: run context cancelled.")
390394
return runCtx.Err()
391395
}
392396
}

0 commit comments

Comments
 (0)