LingxinMeng hai 10 meses
pai
achega
9a814996f2
Modificáronse 1 ficheiros con 3 adicións e 1 borrados
  1. 3 1
      src/package/service/run_task.go

+ 3 - 1
src/package/service/run_task.go

@@ -257,7 +257,9 @@ func RunWaitingCluster() {
 		podString = strings.Replace(podString, "algorithm-container", algorithmContainer, -1)
 		// 从xosc中解析起终点位置
 		xoscOssPath := firstTaskCache.Task.Scenario.ScenarioOsc
-		xoscLocalPath := "/mnt/disk001/dcl_dispatch_server/temp/" + util.NewShortUUID() + ".xosc"
+		tempDir := "/mnt/disk001/dcl_dispatch_server/temp/"
+		util.CreateDir(tempDir)
+		xoscLocalPath := tempDir + util.NewShortUUID() + ".xosc"
 		err = infra.GlobalOssBucket.GetObjectToFile(firstTaskCache.Task.Scenario.ScenarioOsc, xoscLocalPath)
 		if err != nil {
 			infra.GlobalLogger.Errorf("下载xosc文件 %v 失败,错误信息为:%v", xoscOssPath, err)