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")
 			}
 		}