From 4f79f437b07f49a18366abe2085fa67f129287e5 Mon Sep 17 00:00:00 2001 From: bilal-younus Date: Fri, 6 Nov 2026 12:13:38 +0100 Subject: [PATCH] fix(output): synchronize the prefixed writer buffer --- internal/output/prefixed.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/internal/output/prefixed.go b/internal/output/prefixed.go index fd2a230570..930008e3bf 100644 --- a/internal/output/prefixed.go +++ b/internal/output/prefixed.go @@ -38,9 +38,13 @@ type prefixWriter struct { prefixed *Prefixed prefix string buff bytes.Buffer + mutex sync.Mutex } func (pw *prefixWriter) Write(p []byte) (int, error) { + pw.mutex.Lock() + defer pw.mutex.Unlock() + n, err := pw.buff.Write(p) if err != nil { return n, err @@ -50,6 +54,9 @@ func (pw *prefixWriter) Write(p []byte) (int, error) { } func (pw *prefixWriter) close() error { + pw.mutex.Lock() + defer pw.mutex.Unlock() + return pw.writeOutputLines(true) }