From 959a235c59d2ba839149150bb04690ee99024ef8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Sybren=20A=2E=20St=C3=BCvel?= Date: Fri, 8 Apr 2022 16:48:28 +0200 Subject: [PATCH] Worker: don't log error when rolling back already-committed transaction --- cmd/flamenco-worker/main.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cmd/flamenco-worker/main.go b/cmd/flamenco-worker/main.go index 97980041..ec8cceb2 100644 --- a/cmd/flamenco-worker/main.go +++ b/cmd/flamenco-worker/main.go @@ -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") } }