Signed-off-by: bnechyporenko <bnechyporenko@bol.com>
This commit is contained in:
bnechyporenko
2024-01-21 20:31:16 +01:00
parent 6ac91e8180
commit 90fbb8e95d
@@ -484,7 +484,7 @@ export class DatabaseTaskStore implements TaskStore {
async recoverTasks(
options: TaskStoreRecoverTaskOptions,
): Promise<{ id: string }[]> {
const taskIdsToRecover: string[] = [];
const taskIdsToRecover: { id: string }[] = [];
const timeoutS = Duration.fromObject(options.timeout).as('seconds');
await this.db.transaction(async tx => {
@@ -501,7 +501,7 @@ export class DatabaseTaskStore implements TaskStore {
['id', 'spec'],
);
taskIdsToRecover.push(...result.map(i => i.id));
taskIdsToRecover.push(...result.map(i => ({ id: i.id })));
for (const { id, spec } of result) {
const taskSpec = JSON.parse(spec as string) as TaskSpec;
@@ -516,6 +516,6 @@ export class DatabaseTaskStore implements TaskStore {
}
});
return taskIdsToRecover.map(id => ({ id }));
return taskIdsToRecover;
}
}