|
@@ -285,7 +285,8 @@ export class TaskService implements OnModuleInit {
|
|
|
useBackup: data.useBackup,
|
|
useBackup: data.useBackup,
|
|
|
e2ee: data.e2ee,
|
|
e2ee: data.e2ee,
|
|
|
e2eeTimeout: data.e2eeTimeout,
|
|
e2eeTimeout: data.e2eeTimeout,
|
|
|
- confusion: data.confusion
|
|
|
|
|
|
|
+ confusion: data.confusion,
|
|
|
|
|
+ remark: data.remark
|
|
|
}
|
|
}
|
|
|
)
|
|
)
|
|
|
}
|
|
}
|
|
@@ -1367,7 +1368,13 @@ export class TaskService implements OnModuleInit {
|
|
|
if (nextTasksIds.length === 0) {
|
|
if (nextTasksIds.length === 0) {
|
|
|
nextTasksIds.push(...nextTasks.map((t) => t.id).slice(0, limit))
|
|
nextTasksIds.push(...nextTasks.map((t) => t.id).slice(0, limit))
|
|
|
}
|
|
}
|
|
|
- await this.taskRepository.update({ id: In(nextTasksIds) }, { status: TaskStatus.PENDING })
|
|
|
|
|
|
|
+ await this.taskRepository.update(
|
|
|
|
|
+ { id: In(nextTasksIds) },
|
|
|
|
|
+ {
|
|
|
|
|
+ status: TaskStatus.PENDING,
|
|
|
|
|
+ startedAt: new Date()
|
|
|
|
|
+ }
|
|
|
|
|
+ )
|
|
|
tasks.push(...filteredTasks)
|
|
tasks.push(...filteredTasks)
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|