From 6a3ac35b54e8106e1db11fbbed787d6b6c56f199 Mon Sep 17 00:00:00 2001 From: Peter Swica Date: Fri, 7 Jun 2019 01:13:40 -0400 Subject: [PATCH] added defer keyword to wg.Done() in logs.go --- pkg/kubectl/cmd/logs/logs.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/kubectl/cmd/logs/logs.go b/pkg/kubectl/cmd/logs/logs.go index 15774199603..fd21373ddf9 100644 --- a/pkg/kubectl/cmd/logs/logs.go +++ b/pkg/kubectl/cmd/logs/logs.go @@ -324,6 +324,7 @@ func (o LogsOptions) parallelConsumeRequest(requests []rest.ResponseWrapper) err wg.Add(len(requests)) for _, request := range requests { go func(request rest.ResponseWrapper) { + defer wg.Done() if err := o.ConsumeRequestFn(request, writer); err != nil { if !o.IgnoreLogErrors { writer.CloseWithError(err) @@ -335,7 +336,6 @@ func (o LogsOptions) parallelConsumeRequest(requests []rest.ResponseWrapper) err fmt.Fprintf(writer, "error: %v\n", err) } - wg.Done() }(request) }