diff --git a/internal/backend/backup/jobrun.go b/internal/backend/backup/jobrun.go index 7dc25af..80d0f0e 100644 --- a/internal/backend/backup/jobrun.go +++ b/internal/backend/backup/jobrun.go @@ -137,7 +137,6 @@ func RunBackup(job *store.Job, storeInstance *store.Store, waitChan chan struct{ go func() { taskC := <-taskChan task = &taskC - cancel() }() for { @@ -153,8 +152,6 @@ func RunBackup(job *store.Job, storeInstance *store.Store, waitChan chan struct{ time.Sleep(time.Millisecond * 100) } - <-watchCtx.Done() - if task == nil { return nil, fmt.Errorf("RunBackup: task not found -> %w", err) }