fix: create dir when input path is not exist in oss (#12323)

Signed-off-by: shuangkun <[email protected]> Co-authored-by: zjgemi <[email protected]>
argoproj · May 5, 2024 · fedfb37 · fedfb37
1 parent a68e1f0
commit fedfb37
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/workflow/artifacts/oss/oss.go b/workflow/artifacts/oss/oss.go
@@ -70,6 +70,11 @@ func (ossDriver *ArtifactDriver) Load(inputArtifact *wfv1.Artifact, path string)
  return !isTransientOSSErr(err), err
  }
  objectName := inputArtifact.OSS.Key
+ dirPath := filepath.Dir(path)
+ err = os.MkdirAll(dirPath, 0o700)
+ if err != nil {
+ return false, fmt.Errorf("mkdir %s error: %w", dirPath, err)
+ }
  origErr := bucket.GetObjectToFile(objectName, path)
  if origErr == nil {
  return true, nil