fm453/nocobase
1
0
Fork 0
mirror of https://gitee.com/nocobase/nocobase.git synced 2025-05-05 13:39:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: test

Browse Source
This commit is contained in:
aaaaaajie 2025-05-03 21:08:47 +08:00
parent 478d836404
commit 91f8da7aa1
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
packages/plugins/@nocobase/plugin-async-task-manager/src/server/task-type.ts
View File

@ -150,6 +150,7 @@ export abstract class TaskType extends EventEmitter implements ITask {
if (error instanceof CancelError) { if (error instanceof CancelError) {
this.statusChange({ type: 'cancelled' }); this.statusChange({ type: 'cancelled' });
this.logger?.info(`Task ${this.taskId} was cancelled during execution`); this.logger?.info(`Task ${this.taskId} was cancelled during execution`);
return;
} else { } else {
this.status = { this.status = {
type: 'failed', type: 'failed',
@ -158,9 +159,8 @@ export abstract class TaskType extends EventEmitter implements ITask {
}; };
this.logger?.error(`Task ${this.taskId} failed with error: ${error.message}`); this.logger?.error(`Task ${this.taskId} failed with error: ${error.message}`);
}
this.emit('statusChange', this.status); this.emit('statusChange', this.status);
}
} finally { } finally {
this.fulfilledAt = new Date(); this.fulfilledAt = new Date();
const duration = this.fulfilledAt.getTime() - this.startedAt.getTime(); const duration = this.fulfilledAt.getTime() - this.startedAt.getTime();