executor: reuse taskPath function
This commit is contained in:
parent
48411f4c64
commit
629cf2be82
|
@ -1163,7 +1163,7 @@ func (e *Executor) tasksDataCleaner(ctx context.Context) error {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if resp.StatusCode == http.StatusNotFound {
|
if resp.StatusCode == http.StatusNotFound {
|
||||||
taskDir := filepath.Join(e.tasksDir(), entry.Name())
|
taskDir := e.taskPath(etID)
|
||||||
log.Infof("removing task dir %q", taskDir)
|
log.Infof("removing task dir %q", taskDir)
|
||||||
// remove task dir
|
// remove task dir
|
||||||
if err := os.RemoveAll(taskDir); err != nil {
|
if err := os.RemoveAll(taskDir); err != nil {
|
||||||
|
|
Loading…
Reference in New Issue