From 017e41e12e08ae8239fbd024ecefa76324b0d236 Mon Sep 17 00:00:00 2001 From: restitux Date: Mon, 17 Oct 2022 01:19:41 -0600 Subject: [PATCH] Delete job working directory if it already exists --- runner/runner.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/runner/runner.go b/runner/runner.go index d9e341b..506916f 100644 --- a/runner/runner.go +++ b/runner/runner.go @@ -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) }