Worker: don't log error when rolling back already-committed transaction

This commit is contained in:
Sybren A. Stüvel 2022-04-08 16:48:28 +02:00
parent f155715d12
commit 959a235c59

View File

@ -133,7 +133,7 @@ func shutdown(signum os.Signal) {
w.SignOff(shutdownCtx)
w.Close()
listener.Wait()
if err := buffer.Close(shutdownCtx); err != nil {
if err := buffer.Close(); err != nil {
log.Error().Err(err).Msg("closing upstream task buffer")
}
}