From 988e6d1a2db84e433798cc111a6dfd86731c89f9 Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Mon, 22 Dec 2025 00:36:38 -0800 Subject: [PATCH] Update weed/worker/client.go Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> --- weed/worker/client.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/weed/worker/client.go b/weed/worker/client.go index 5b8df5763..2545ef5d8 100644 --- a/weed/worker/client.go +++ b/weed/worker/client.go @@ -345,7 +345,7 @@ func handleOutgoing( msgCh := make(chan *worker_pb.WorkerMessage, 1) errCh := make(chan error, 1) // Buffered to prevent blocking if the manager is busy - // Goroutine that performs the blocking stream.Send() calls. + // Goroutine that reads from msgCh and performs the blocking stream.Send() calls. go func() { for msg := range msgCh { if err := stream.Send(msg); err != nil {