chore: Lint master

cmd/argo/commands/server_test.go

@@ -1,9 +1,10 @@
 package commands
 
 import (
- "github.com/stretchr/testify/assert"
  "os"
  "testing"
+
+ "github.com/stretchr/testify/assert"
 )
 
 func TestDefaultSecureMode(t *testing.T) {

cmd/argo/lint/lint_test.go

@@ -68,7 +68,7 @@ spec:
 func TestLintFile(t *testing.T) {
  file, err := ioutil.TempFile("", "*.yaml")
  assert.NoError(t, err)
- err = ioutil.WriteFile(file.Name(), lintFileData, 0644)
+ err = ioutil.WriteFile(file.Name(), lintFileData, 0o644)
  assert.NoError(t, err)
  defer os.Remove(file.Name())
 
@@ -97,7 +97,7 @@ func TestLintFile(t *testing.T) {
 func TestLintMultipleKinds(t *testing.T) {
  file, err := ioutil.TempFile("", "*.yaml")
  assert.NoError(t, err)
- err = ioutil.WriteFile(file.Name(), lintFileData, 0644)
+ err = ioutil.WriteFile(file.Name(), lintFileData, 0o644)
  assert.NoError(t, err)
  defer os.Remove(file.Name())
 
@@ -129,7 +129,7 @@ func TestLintMultipleKinds(t *testing.T) {
 func TestLintWithOutput(t *testing.T) {
  file, err := ioutil.TempFile("", "*.yaml")
  assert.NoError(t, err)
- err = ioutil.WriteFile(file.Name(), lintFileData, 0644)
+ err = ioutil.WriteFile(file.Name(), lintFileData, 0o644)
  assert.NoError(t, err)
  defer os.Remove(file.Name())
 

cmd/argoexec/commands/emissary.go

@@ -39,14 +39,14 @@ func NewEmissaryCommand() *cobra.Command {
  exitCode := 64
 
  defer func() {
- err := ioutil.WriteFile(varRunArgo+"/ctr/"+containerName+"/exitcode", []byte(strconv.Itoa(exitCode)), 0600)
+ err := ioutil.WriteFile(varRunArgo+"/ctr/"+containerName+"/exitcode", []byte(strconv.Itoa(exitCode)), 0o600)
  if err != nil {
  logger.Error(fmt.Errorf("failed to write exit code: %w", err))
  }
  }()
 
  // this also indicates we've started
- if err := os.MkdirAll(varRunArgo+"/ctr/"+containerName, 0700); err != nil {
+ if err := os.MkdirAll(varRunArgo+"/ctr/"+containerName, 0o700); err != nil {
  return fmt.Errorf("failed to create ctr directory: %w", err)
  }
 
@@ -190,7 +190,7 @@ func saveArtifact(srcPath string) error {
  dstPath := varRunArgo + "/outputs/artifacts/" + srcPath + ".tgz"
  logger.Infof("%s -> %s", srcPath, dstPath)
  z := filepath.Dir(dstPath)
- if err := os.MkdirAll(z, 0700); err != nil { // chmod rwx------
+ if err := os.MkdirAll(z, 0o700); err != nil { // chmod rwx------
  return fmt.Errorf("failed to create directory %s: %w", z, err)
  }
  dst, err := os.Create(dstPath)
@@ -224,7 +224,7 @@ func saveParameter(srcPath string) error {
  dstPath := varRunArgo + "/outputs/parameters/" + srcPath
  logger.Infof("%s -> %s", srcPath, dstPath)
  z := filepath.Dir(dstPath)
- if err := os.MkdirAll(z, 0700); err != nil { // chmod rwx------
+ if err := os.MkdirAll(z, 0o700); err != nil { // chmod rwx------
  return fmt.Errorf("failed to create directory %s: %w", z, err)
  }
  dst, err := os.Create(dstPath)

cmd/argoexec/commands/emissary_test.go

@@ -26,7 +26,7 @@ func TestEmissary(t *testing.T) {
 
  x := filepath.Join(wd, "../../../dist/argosay")
 
- err = ioutil.WriteFile(varRunArgo+"/template", []byte(`{}`), 0600)
+ err = ioutil.WriteFile(varRunArgo+"/template", []byte(`{}`), 0o600)
  assert.NoError(t, err)
 
  t.Run("Exit0", func(t *testing.T) {
@@ -62,7 +62,7 @@ func TestEmissary(t *testing.T) {
  syscall.SIGTERM: "terminated",
  syscall.SIGKILL: "killed",
  } {
- err := ioutil.WriteFile(varRunArgo+"/ctr/main/signal", []byte(strconv.Itoa(int(signal))), 0600)
+ err := ioutil.WriteFile(varRunArgo+"/ctr/main/signal", []byte(strconv.Itoa(int(signal))), 0o600)
  assert.NoError(t, err)
  var wg sync.WaitGroup
  wg.Add(1)
@@ -83,7 +83,7 @@ func TestEmissary(t *testing.T) {
  ]
  }
 }
-`), 0600)
+`), 0o600)
  assert.NoError(t, err)
  err := run(x, []string{"echo", "hello", "/tmp/artifact"})
  assert.NoError(t, err)
@@ -102,7 +102,7 @@ func TestEmissary(t *testing.T) {
  ]
  }
 }
-`), 0600)
+`), 0o600)
  assert.NoError(t, err)
  err := run(x, []string{"echo", "hello", "/tmp/parameter"})
  assert.NoError(t, err)

examples/example-golang/main.go

@@ -18,25 +18,23 @@ import (
  wfclientset "github.com/argoproj/argo-workflows/v3/pkg/client/clientset/versioned"
 )
 
-var (
- helloWorldWorkflow = wfv1.Workflow{
- ObjectMeta: metav1.ObjectMeta{
- GenerateName: "hello-world-",
- },
- Spec: wfv1.WorkflowSpec{
- Entrypoint: "whalesay",
- Templates: []wfv1.Template{
- {
- Name: "whalesay",
- Container: &corev1.Container{
- Image: "docker/whalesay:latest",
- Command: []string{"cowsay", "hello world"},
- },
+var helloWorldWorkflow = wfv1.Workflow{
+ ObjectMeta: metav1.ObjectMeta{
+ GenerateName: "hello-world-",
+ },
+ Spec: wfv1.WorkflowSpec{
+ Entrypoint: "whalesay",
+ Templates: []wfv1.Template{
+ {
+ Name: "whalesay",
+ Container: &corev1.Container{
+ Image: "docker/whalesay:latest",
+ Command: []string{"cowsay", "hello world"},
  },
  },
  },
- }
-)
+ },
+}
 
 func main() {
  // get current user to determine home directory

examples/validation_test.go

@@ -12,7 +12,7 @@ func TestValidateExamples(t *testing.T) {
  t.Errorf("There was an error: %s", err)
  }
  if len(failures) > 0 {
- var fails = []string{}
+ fails := []string{}
  for path, fail := range failures {
  fails = append(fails, fmt.Sprintf("Validation failed - %s: %s", path, strings.Join(fail, "\n")))
  }

examples/validator.go

@@ -21,7 +21,6 @@ func contains(s []string, e string) bool {
 }
 
 func ValidateArgoYamlRecursively(fromPath string, skipFileNames []string) (map[string][]string, error) {
-
  schemaBytes, err := ioutil.ReadFile("../api/jsonschema/schema.json")
  if err != nil {
  return nil, err
@@ -36,7 +35,7 @@ func ValidateArgoYamlRecursively(fromPath string, skipFileNames []string) (map[s
  return err
  }
  if contains(skipFileNames, info.Name()) {
- //fmt.Printf("skipping %+v \n", info.Name())
+ // fmt.Printf("skipping %+v \n", info.Name())
  return filepath.SkipDir
  }
  if info.IsDir() {

hack/crds.go

@@ -43,7 +43,7 @@ func cleanCRD(filename string) {
  if err != nil {
  panic(err)
  }
- err = ioutil.WriteFile(filename, data, 0666)
+ err = ioutil.WriteFile(filename, data, 0o666)
  if err != nil {
  panic(err)
  }
@@ -72,7 +72,7 @@ func removeCRDValidation(filename string) {
  if err != nil {
  panic(err)
  }
- err = ioutil.WriteFile(filename, data, 0666)
+ err = ioutil.WriteFile(filename, data, 0o666)
  if err != nil {
  panic(err)
  }

hack/docgen.go

@@ -345,7 +345,7 @@ func (c *DocGeneratorContext) generate() string {
 func generateDocs() {
  println("generating docs/fields.md")
  c := NewDocGeneratorContext()
- err := ioutil.WriteFile("docs/fields.md", []byte(c.generate()), 0644)
+ err := ioutil.WriteFile("docs/fields.md", []byte(c.generate()), 0o644)
  if err != nil {
  panic(err)
  }

hack/parse_examples.go

@@ -35,7 +35,7 @@ func parseExamples() {
  file = linkRegex.ReplaceAll(file, []byte(newLink))
  file = detailsRegex.ReplaceAll(file, []byte(newDetails))
 
- err = ioutil.WriteFile("site/fields/index.html", file, 0644)
+ err = ioutil.WriteFile("site/fields/index.html", file, 0o644)
  if err != nil {
  panic(err)
  }

hack/swagger/secondaryswaggergen.go

@@ -51,7 +51,7 @@ func secondarySwaggerGen() {
  panic(err)
  }
  newContents := strings.ReplaceAll(string(read), "argo-workflows", "argo_workflows")
- err = ioutil.WriteFile("pkg/apiclient/_.secondary.swagger.json", []byte(newContents), 0666)
+ err = ioutil.WriteFile("pkg/apiclient/_.secondary.swagger.json", []byte(newContents), 0o666)
  if err != nil {
  panic(err)
  }

server/artifacts/artifact_server_test.go

@@ -42,7 +42,7 @@ type fakeArtifactDriver struct {
 }
 
 func (a *fakeArtifactDriver) Load(_ *wfv1.Artifact, path string) error {
- return ioutil.WriteFile(path, a.data, 0666)
+ return ioutil.WriteFile(path, a.data, 0o666)
 }
 
 func (a *fakeArtifactDriver) Save(_ string, _ *wfv1.Artifact) error {

server/auth/serviceaccount/claims_test.go

@@ -41,7 +41,7 @@ func TestClaimSetFor(t *testing.T) {
  // set-up test
  tmp, err := ioutil.TempFile("", "")
  assert.NoError(t, err)
- err = ioutil.WriteFile(tmp.Name(), []byte(token), 0644)
+ err = ioutil.WriteFile(tmp.Name(), []byte(token), 0o644)
  assert.NoError(t, err)
  defer func() { _ = os.Remove(tmp.Name()) }()
 

test/e2e/cli_test.go

@@ -657,7 +657,7 @@ func (s *CLISuite) TestWorkflowLint() {
  data, err := ioutil.ReadFile("smoke/basic.yaml")
  s.CheckError(err)
  // Write data to dst
- err = ioutil.WriteFile(filepath.Join(tmp, "my-workflow.yaml"), data, 0644)
+ err = ioutil.WriteFile(filepath.Join(tmp, "my-workflow.yaml"), data, 0o644)
  s.CheckError(err)
  s.Given().
  RunCli([]string{"lint", tmp}, func(t *testing.T, output string, err error) {

util/archive/archive_test.go

@@ -17,7 +17,7 @@ func tempFile(dir, prefix, suffix string) (*os.File, error) {
  if dir == "" {
  dir = os.TempDir()
  } else {
- err := os.MkdirAll(dir, 0700)
+ err := os.MkdirAll(dir, 0o700)
  if err != nil {
  return nil, err
  }

util/file/fileutil_test.go

@@ -39,7 +39,7 @@ func TestExistsInTar(t *testing.T) {
  var buf bytes.Buffer
  writer := tar.NewWriter(&buf)
  for _, f := range files {
- mode := os.FileMode(0600)
+ mode := os.FileMode(0o600)
  if f.isDir {
  mode |= os.ModeDir
  }

util/util.go

@@ -51,7 +51,7 @@ func GetSecrets(ctx context.Context, clientSet kubernetes.Interface, namespace,
 
 // Write the Terminate message in pod spec
 func WriteTeriminateMessage(message string) {
- err := ioutil.WriteFile("/dev/termination-log", []byte(message), 0644)
+ err := ioutil.WriteFile("/dev/termination-log", []byte(message), 0o644)
  if err != nil {
  panic(err)
  }

workflow/artifacts/gcs/gcs.go

@@ -107,7 +107,7 @@ func downloadObject(client *storage.Client, bucket, key, objName, path string) e
  localPath := filepath.Join(path, relObjPath)
  objectDir, _ := filepath.Split(localPath)
  if objectDir != "" {
- if err := os.MkdirAll(objectDir, 0700); err != nil {
+ if err := os.MkdirAll(objectDir, 0o700); err != nil {
  return fmt.Errorf("mkdir %s: %v", objectDir, err)
  }
  }

workflow/artifacts/git/git.go

@@ -41,7 +41,7 @@ func (g *ArtifactDriver) auth() (func(), transport.AuthMethod, []string, error)
  if err != nil {
  return nil, nil, nil, err
  }
- err = ioutil.WriteFile(privateKeyFile.Name(), []byte(g.SSHPrivateKey), 0600)
+ err = ioutil.WriteFile(privateKeyFile.Name(), []byte(g.SSHPrivateKey), 0o600)
  if err != nil {
  return nil, nil, nil, err
  }
@@ -77,7 +77,7 @@ case "$1" in
 Username*) echo "${GIT_USERNAME}" ;;
 Password*) echo "${GIT_PASSWORD}" ;;
 esac
-`), 0755)
+`), 0o755)
  if err != nil {
  return nil, nil, nil, err
  }

workflow/artifacts/git/git_test.go

@@ -17,7 +17,7 @@ func TestGitArtifactDriver_Load(t *testing.T) {
  driver := &ArtifactDriver{}
  path := "/tmp/git-found"
  assert.NoError(t, os.RemoveAll(path))
- assert.NoError(t, os.MkdirAll(path, 0777))
+ assert.NoError(t, os.MkdirAll(path, 0o777))
  err := driver.Load(&wfv1.Artifact{
  ArtifactLocation: wfv1.ArtifactLocation{
  Git: &wfv1.GitArtifact{

workflow/artifacts/hdfs/hdfs.go

@@ -159,7 +159,7 @@ func (driver *ArtifactDriver) Load(_ *wfv1.Artifact, path string) error {
  dirPath := filepath.Dir(driver.Path)
  if dirPath != "." && dirPath != "/" {
  // Follow umask for the permission
- err = os.MkdirAll(dirPath, 0777)
+ err = os.MkdirAll(dirPath, 0o777)
  if err != nil {
  return err
  }
@@ -208,7 +208,7 @@ func (driver *ArtifactDriver) Save(path string, outputArtifact *wfv1.Artifact) e
  dirPath := filepath.Dir(driver.Path)
  if dirPath != "." && dirPath != "/" {
  // Follow umask for the permission
- err = hdfscli.MkdirAll(dirPath, 0777)
+ err = hdfscli.MkdirAll(dirPath, 0o777)
  if err != nil {
  return err
  }

workflow/executor/common/common.go

@@ -150,7 +150,7 @@ func CopyArchive(ctx context.Context, c KubernetesClientInterface, containerName
  if err != nil {
  return err
  }
- f, err := os.OpenFile(destPath, os.O_CREATE|os.O_TRUNC|os.O_WRONLY, 0666)
+ f, err := os.OpenFile(destPath, os.O_CREATE|os.O_TRUNC|os.O_WRONLY, 0o666)
  if err != nil {
  return err
  }

workflow/executor/emissary/binary.go

@@ -16,7 +16,7 @@ func copyBinary() error {
  return err
  }
  defer func() { _ = in.Close() }()
- out, err := os.OpenFile("/var/run/argo/argoexec", os.O_RDWR|os.O_CREATE, 0500) // r-x------
+ out, err := os.OpenFile("/var/run/argo/argoexec", os.O_RDWR|os.O_CREATE, 0o500) // r-x------
  if err != nil {
  return err
  }

workflow/executor/emissary/emissary.go

@@ -62,7 +62,7 @@ func (e emissary) writeTemplate(t wfv1.Template) error {
  if err != nil {
  return err
  }
- return ioutil.WriteFile("/var/run/argo/template", data, 0400) // chmod -r--------
+ return ioutil.WriteFile("/var/run/argo/template", data, 0o400) // chmod -r--------
 }
 
 func (e emissary) GetFileContents(_ string, sourcePath string) (string, error) {
@@ -137,7 +137,7 @@ func (e emissary) isComplete(containerNames []string) bool {
 
 func (e emissary) Kill(ctx context.Context, containerNames []string, terminationGracePeriodDuration time.Duration) error {
  for _, containerName := range containerNames {
- if err := ioutil.WriteFile("/var/run/argo/ctr/"+containerName+"/signal", []byte(strconv.Itoa(int(syscall.SIGTERM))), 0600); err != nil {
+ if err := ioutil.WriteFile("/var/run/argo/ctr/"+containerName+"/signal", []byte(strconv.Itoa(int(syscall.SIGTERM))), 0o600); err != nil {
  return err
  }
  }
@@ -148,7 +148,7 @@ func (e emissary) Kill(ctx context.Context, containerNames []string, termination
  return err
  }
  for _, containerName := range containerNames {
- if err := ioutil.WriteFile("/var/run/argo/ctr/"+containerName+"/signal", []byte(strconv.Itoa(int(syscall.SIGKILL))), 0600); err != nil {
+ if err := ioutil.WriteFile("/var/run/argo/ctr/"+containerName+"/signal", []byte(strconv.Itoa(int(syscall.SIGKILL))), 0o600); err != nil {
  return err
  }
  }

workflow/executor/executor.go

@@ -251,7 +251,7 @@ func (we *WorkflowExecutor) StageFiles() error {
  default:
  return nil
  }
- err := ioutil.WriteFile(filePath, body, 0644)
+ err := ioutil.WriteFile(filePath, body, 0o644)
  if err != nil {
  return errors.InternalWrapError(err)
  }