|
@@ -197,7 +197,10 @@ export class TaskService implements OnModuleInit {
|
|
|
}
|
|
}
|
|
|
})
|
|
})
|
|
|
|
|
|
|
|
- await this.taskRepository.update({ id }, { status: num > 0 ? TaskStatus.QUEUED : TaskStatus.PENDING })
|
|
|
|
|
|
|
+ await this.taskRepository.update({ id }, {
|
|
|
|
|
+ status: num > 0 ? TaskStatus.QUEUED : TaskStatus.PENDING,
|
|
|
|
|
+ startedAt: new Date()
|
|
|
|
|
+ })
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
async pauseTask(id: number): Promise<void> {
|
|
async pauseTask(id: number): Promise<void> {
|
|
@@ -271,7 +274,7 @@ export class TaskService implements OnModuleInit {
|
|
|
status: TaskStatus.QUEUED
|
|
status: TaskStatus.QUEUED
|
|
|
},
|
|
},
|
|
|
order: {
|
|
order: {
|
|
|
- createdAt: 'ASC'
|
|
|
|
|
|
|
+ startedAt: 'ASC'
|
|
|
}
|
|
}
|
|
|
})
|
|
})
|
|
|
if (tasks.length > 0) {
|
|
if (tasks.length > 0) {
|
|
@@ -363,7 +366,7 @@ export class TaskService implements OnModuleInit {
|
|
|
status: TaskStatus.QUEUED
|
|
status: TaskStatus.QUEUED
|
|
|
},
|
|
},
|
|
|
order: {
|
|
order: {
|
|
|
- createdAt: 'ASC'
|
|
|
|
|
|
|
+ startedAt: 'ASC'
|
|
|
}
|
|
}
|
|
|
})
|
|
})
|
|
|
// 异步执行startTask方法
|
|
// 异步执行startTask方法
|
|
@@ -493,7 +496,7 @@ export class TaskService implements OnModuleInit {
|
|
|
status: TaskStatus.QUEUED
|
|
status: TaskStatus.QUEUED
|
|
|
},
|
|
},
|
|
|
order: {
|
|
order: {
|
|
|
- createdAt: 'ASC'
|
|
|
|
|
|
|
+ startedAt: 'ASC'
|
|
|
}
|
|
}
|
|
|
})
|
|
})
|
|
|
if (nextTask) {
|
|
if (nextTask) {
|