#4722 合入删除任务时删除本地及S3的资源

Merged
chenyifan01 merged 3 commits from zouap_static into V20230912 7 months ago
  1. +6
    -2
      services/cloudbrain/cloudbrainTask/common.go

+ 6
- 2
services/cloudbrain/cloudbrainTask/common.go View File

@@ -10,16 +10,20 @@ import (

func DeleteCloudbrainJobStorage(jobName string, cloudbrainType int) error {
//delete local
if jobName == "" {
log.Info("This is error.jobName is empty.")
return nil
}
localJobPath := setting.JobPath + jobName
err := os.RemoveAll(localJobPath)
if err != nil {
log.Error("RemoveAll(%s) failed:%v", localJobPath, err)
}
deleteS3Storage(jobName, cloudbrainType)
deleteS3Storage(jobName)
return nil
}

func deleteS3Storage(jobName string, cloudbrainType int) {
func deleteS3Storage(jobName string) {
//delete oss

dirPath := setting.CBCodePathPrefix + jobName + "/"


Loading…
Cancel
Save