Create a new run engine event bus event for the runs dashboard to hook into

Author: ericallam

apps/webapp/app/services/runsDashboardInstance.server.ts

@@ -7,6 +7,8 @@ import {
 } from "./runsDashboardService.server";
 import { EventEmitter } from "node:events";
 import { RuntimeEnvironmentType, TaskRun } from "@trigger.dev/database";
+import { engine } from "~/v3/runEngine.server";
+import { logger } from "./logger.server";
 
 const runDashboardEventBus: RunDashboardEventBus = new EventEmitter<RunDashboardEvents>();
 
@@ -32,5 +34,13 @@ export const runsDashboard = singleton("runsDashboard", () => {
     await service.upsertRun(event.run, event.environment.type, event.organization.id);
   });
 
+  engine.eventBus.on("runStatusChanged", async (event) => {
+    logger.debug("RunDashboard: runStatusChanged", {
+      event,
+    });
+
+    await service.upsertRun(event.run, event.environment.type, event.environment.organization.id);
+  });
+
   return service;
 });

apps/webapp/app/v3/services/triggerTaskV1.server.ts

@@ -43,6 +43,7 @@ import {
 import { getTaskEventStore } from "../taskEventStore.server";
 import { enqueueRun } from "./enqueueRun.server";
 import { z } from "zod";
+import { emitRunStatusUpdate } from "~/services/runsDashboardInstance.server";
 
 // This is here for backwords compatibility for v3 users
 const QueueOptions = z.object({
@@ -601,6 +602,8 @@ export class TriggerTaskServiceV1 extends BaseService {
           return;
         }
 
+        emitRunStatusUpdate(run, environment);
+
         return {
           run,
           isCached: result?.isCached,