Skip to content

Commit

Permalink
fix(executor): Remove IsTransientErr check for ExponentialBackoff. Fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
anggao committed Oct 2, 2020
1 parent f7e85f0 commit 2b12762
Showing 1 changed file with 0 additions and 10 deletions.
10 changes: 0 additions & 10 deletions workflow/executor/executor.go
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,6 @@ import (
wfv1 "github.com/argoproj/argo/pkg/apis/workflow/v1alpha1"
"github.com/argoproj/argo/util"
"github.com/argoproj/argo/util/archive"
errorsutil "github.com/argoproj/argo/util/errors"
"github.com/argoproj/argo/util/retry"
artifact "github.com/argoproj/argo/workflow/artifacts"
"github.com/argoproj/argo/workflow/common"
Expand Down Expand Up @@ -619,9 +618,6 @@ func (we *WorkflowExecutor) getPod() (*apiv1.Pod, error) {
pod, err = podsIf.Get(we.PodName, metav1.GetOptions{})
if err != nil {
log.Warnf("Failed to get pod '%s': %v", we.PodName, err)
if !errorsutil.IsTransientErr(err) {
return false, err
}
return false, nil
}
return true, nil
Expand All @@ -646,9 +642,6 @@ func (we *WorkflowExecutor) GetConfigMapKey(name, key string) (string, error) {
configmap, err = configmapsIf.Get(name, metav1.GetOptions{})
if err != nil {
log.Warnf("Failed to get configmap '%s': %v", name, err)
if !errorsutil.IsTransientErr(err) {
return false, err
}
return false, nil
}
return true, nil
Expand Down Expand Up @@ -681,9 +674,6 @@ func (we *WorkflowExecutor) GetSecrets(namespace, name, key string) ([]byte, err
secret, err = secretsIf.Get(name, metav1.GetOptions{})
if err != nil {
log.Warnf("Failed to get secret '%s': %v", name, err)
if !errorsutil.IsTransientErr(err) {
return false, err
}
return false, nil
}
return true, nil
Expand Down

0 comments on commit 2b12762

Please sign in to comment.