Merge pull request #31806 from mmorel-35/errorlint-pkg-4-15f432a

fix(pkg): errorlint linter
pull/31800/head
George Jenkins 7 months ago committed by GitHub
commit be7cdb69e5
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

@ -455,7 +455,7 @@ func (u *Upgrade) releasingUpgrade(c chan<- resultMessage, upgradedRelease *rele
if !u.DisableHooks { if !u.DisableHooks {
if err := u.cfg.execHook(upgradedRelease, release.HookPreUpgrade, u.WaitStrategy, u.WaitOptions, u.Timeout, serverSideApply); err != nil { if err := u.cfg.execHook(upgradedRelease, release.HookPreUpgrade, u.WaitStrategy, u.WaitOptions, u.Timeout, serverSideApply); err != nil {
u.reportToPerformUpgrade(c, upgradedRelease, kube.ResourceList{}, fmt.Errorf("pre-upgrade hooks failed: %s", err)) u.reportToPerformUpgrade(c, upgradedRelease, kube.ResourceList{}, fmt.Errorf("pre-upgrade hooks failed: %w", err))
return return
} }
} else { } else {
@ -503,7 +503,7 @@ func (u *Upgrade) releasingUpgrade(c chan<- resultMessage, upgradedRelease *rele
// post-upgrade hooks // post-upgrade hooks
if !u.DisableHooks { if !u.DisableHooks {
if err := u.cfg.execHook(upgradedRelease, release.HookPostUpgrade, u.WaitStrategy, u.WaitOptions, u.Timeout, serverSideApply); err != nil { if err := u.cfg.execHook(upgradedRelease, release.HookPostUpgrade, u.WaitStrategy, u.WaitOptions, u.Timeout, serverSideApply); err != nil {
u.reportToPerformUpgrade(c, upgradedRelease, results.Created, fmt.Errorf("post-upgrade hooks failed: %s", err)) u.reportToPerformUpgrade(c, upgradedRelease, results.Created, fmt.Errorf("post-upgrade hooks failed: %w", err))
return return
} }
} }

@ -16,6 +16,7 @@ limitations under the License.
package v2 package v2
import ( import (
"errors"
"testing" "testing"
) )
@ -181,7 +182,7 @@ func TestValidate(t *testing.T) {
for _, tt := range tests { for _, tt := range tests {
result := tt.md.Validate() result := tt.md.Validate()
if result != tt.err { if !errors.Is(result, tt.err) {
t.Errorf("expected %q, got %q in test %q", tt.err, result, tt.name) t.Errorf("expected %q, got %q in test %q", tt.err, result, tt.name)
} }
} }

@ -319,7 +319,7 @@ func cleanupParseError(filename string, err error) error {
tokens := strings.Split(err.Error(), ": ") tokens := strings.Split(err.Error(), ": ")
if len(tokens) == 1 { if len(tokens) == 1 {
// This might happen if a non-templating error occurs // This might happen if a non-templating error occurs
return fmt.Errorf("parse error in (%s): %s", filename, err) return fmt.Errorf("parse error in (%s): %w", filename, err)
} }
// The first token is "template" // The first token is "template"
// The second token is either "filename:lineno" or "filename:lineNo:columnNo" // The second token is either "filename:lineno" or "filename:lineNo:columnNo"
@ -462,7 +462,7 @@ func reformatExecErrorMsg(filename string, err error) error {
tokens := strings.SplitN(err.Error(), ": ", 3) tokens := strings.SplitN(err.Error(), ": ", 3)
if len(tokens) != 3 { if len(tokens) != 3 {
// This might happen if a non-templating error occurs // This might happen if a non-templating error occurs
return fmt.Errorf("execution error in (%s): %s", filename, err) return fmt.Errorf("execution error in (%s): %w", filename, err)
} }
// The first token is "template" // The first token is "template"

@ -18,6 +18,7 @@ package kube // import "helm.sh/helm/v4/pkg/kube"
import ( import (
"context" "context"
"errors"
"fmt" "fmt"
"log/slog" "log/slog"
"net/http" "net/http"
@ -107,7 +108,8 @@ func (hw *legacyWaiter) isRetryableError(err error, resource *resource.Info) boo
slog.String("resource", resource.Name), slog.String("resource", resource.Name),
slog.Any("error", err), slog.Any("error", err),
) )
if ev, ok := err.(*apierrors.StatusError); ok { ev := &apierrors.StatusError{}
if errors.As(err, &ev) {
statusCode := ev.Status().Code statusCode := ev.Status().Code
retryable := hw.isRetryableHTTPStatusCode(statusCode) retryable := hw.isRetryableHTTPStatusCode(statusCode)
slog.Debug( slog.Debug(

@ -165,7 +165,7 @@ func TestSecretQuery(t *testing.T) {
} }
_, err = secrets.Query(map[string]string{"name": "notExist"}) _, err = secrets.Query(map[string]string{"name": "notExist"})
if err != ErrReleaseNotFound { if !errors.Is(err, ErrReleaseNotFound) {
t.Errorf("Expected {%v}, got {%v}", ErrReleaseNotFound, err) t.Errorf("Expected {%v}, got {%v}", ErrReleaseNotFound, err)
} }
} }
@ -237,7 +237,7 @@ func TestSecretDelete(t *testing.T) {
// perform the delete on a non-existing release // perform the delete on a non-existing release
_, err := secrets.Delete("nonexistent") _, err := secrets.Delete("nonexistent")
if err != ErrReleaseNotFound { if !errors.Is(err, ErrReleaseNotFound) {
t.Fatalf("Expected ErrReleaseNotFound, got: {%v}", err) t.Fatalf("Expected ErrReleaseNotFound, got: {%v}", err)
} }

Loading…
Cancel
Save