From b4b5a0cf3f37c58454dc717d76fd944f2ec25707 Mon Sep 17 00:00:00 2001 From: Steven Roussey Date: Thu, 30 Jan 2025 15:24:14 -0800 Subject: [PATCH] fix: data from task completion was not saved before completion event fired --- packages/ai/src/task/base/JobQueueLlmTask.ts | 2 +- packages/core/src/task/base/Task.ts | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/packages/ai/src/task/base/JobQueueLlmTask.ts b/packages/ai/src/task/base/JobQueueLlmTask.ts index f2e4070..eff8a9d 100644 --- a/packages/ai/src/task/base/JobQueueLlmTask.ts +++ b/packages/ai/src/task/base/JobQueueLlmTask.ts @@ -48,9 +48,9 @@ export class JobQueueLlmTask extends JobQueueTask { console.error(err); return {}; } - this.emit("complete"); this.runOutputData = results ?? {}; this.runOutputData = await this.runReactive(); + this.emit("complete"); return this.runOutputData; } async runReactive(): Promise { diff --git a/packages/core/src/task/base/Task.ts b/packages/core/src/task/base/Task.ts index dbb927b..3bb4524 100644 --- a/packages/core/src/task/base/Task.ts +++ b/packages/core/src/task/base/Task.ts @@ -298,8 +298,8 @@ export abstract class TaskBase { } this.emit("start"); const result = await this.runReactive(); - this.emit("complete"); this.runOutputData = result; + this.emit("complete"); return result; } /**