fix job progress status always inprogressing

3 years ago · a7a3e7082c
parent 4a4375a796
commit a7a3e7082c
1 changed files with 4 additions and 0 deletions
--- a/pkg/task/import.go
+++ b/pkg/task/import.go
@ -76,6 +76,10 @@ func (job *ImportTask) GetError() *JobError {

 // Do 开始执行任务
 func (job *ImportTask) Do() {
+	defer func() {
+		job.TaskModel.SetProgress(Complete)
+	}()
+
 	ctx := context.Background()

 	// 查找存储策略