Delete job working directory if it already exists

2022-10-17 01:19:41 -06:00
parent f5d7956afd
commit 017e41e12e
1 changed files with 6 additions and 1 deletions
@@ -30,7 +30,12 @@ func RunJob(job Job, workingDir string) error {

 	log.Debugf("Job %v configured with folder \"%v\"", job.Id, jobFolder)

-	err := os.MkdirAll(jobFolder, 0755)
+	err := os.RemoveAll(jobFolder)
+	if err != nil {
+		return fmt.Errorf("could not delete existing folder %v", jobFolder)
+	}
+
+	err = os.MkdirAll(jobFolder, 0755)
 	if err != nil {
 		return fmt.Errorf("could not create working directory for job %v: %v", job.Id, err)
 	}