From 91f8da7aa13d0432531252fee143f6796855f0a4 Mon Sep 17 00:00:00 2001 From: aaaaaajie Date: Sat, 3 May 2025 21:08:47 +0800 Subject: [PATCH] fix: test --- .../plugin-async-task-manager/src/server/task-type.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/packages/plugins/@nocobase/plugin-async-task-manager/src/server/task-type.ts b/packages/plugins/@nocobase/plugin-async-task-manager/src/server/task-type.ts index 20ae3c0f43..2a058b68df 100644 --- a/packages/plugins/@nocobase/plugin-async-task-manager/src/server/task-type.ts +++ b/packages/plugins/@nocobase/plugin-async-task-manager/src/server/task-type.ts @@ -150,6 +150,7 @@ export abstract class TaskType extends EventEmitter implements ITask { if (error instanceof CancelError) { this.statusChange({ type: 'cancelled' }); this.logger?.info(`Task ${this.taskId} was cancelled during execution`); + return; } else { this.status = { 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.emit('statusChange', this.status); } - - this.emit('statusChange', this.status); } finally { this.fulfilledAt = new Date(); const duration = this.fulfilledAt.getTime() - this.startedAt.getTime();