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<TaskOutput> {
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;
   }
   /**