sweepbatcher: log batcher failures

This is useful to debug. It used to fail silently.
This commit is contained in:
Boris Nagaev 2024-06-30 22:59:08 -03:00
parent db5e0d1d27
commit f5e97c035d
No known key found for this signature in database

View file

@ -375,18 +375,22 @@ func (b *Batcher) Run(ctx context.Context) error {
case sweepReq := <-b.sweepReqs:
sweep, err := b.fetchSweep(runCtx, sweepReq)
if err != nil {
log.Warnf("fetchSweep failed: %v.", err)
return err
}
err = b.handleSweep(runCtx, sweep, sweepReq.Notifier)
if err != nil {
log.Warnf("handleSweep failed: %v.", err)
return err
}
case err := <-b.errChan:
log.Warnf("Batcher received an error: %v.", err)
return err
case <-runCtx.Done():
log.Infof("Stopping Batcher: run context cancelled.")
return runCtx.Err()
}
}