Denormalize workflowName into execution store to avoid extra DB queries

Store workflow name directly in execution records and analytics blobs,
eliminating the need to join or fetch workflow names separately when
listing or displaying executions.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: bchapuis

apps/api/src/mocks/execution-store.ts

@@ -28,6 +28,7 @@ export class MockExecutionStore implements ExecutionStore {
     const row: ExecutionRow = {
       id: record.id,
       workflowId: record.workflowId,
+      workflowName: record.workflowName,
       organizationId: record.organizationId,
       status: record.status,
       error: record.error ?? null,

apps/api/src/routes/admin/executions.ts

@@ -5,7 +5,7 @@ import { Hono } from "hono";
 import { z } from "zod";
 
 import { ApiContext } from "../../context";
-import { createDatabase, organizations, workflows } from "../../db";
+import { createDatabase, organizations } from "../../db";
 import { CloudflareExecutionStore } from "../../runtime/cloudflare-execution-store";
 
 const adminExecutionsRoutes = new Hono<ApiContext>();
@@ -127,10 +127,9 @@ adminExecutionsRoutes.get(
       const result = (await response.json()) as { data?: any[] };
       const rows = result.data || [];
 
-      // Get organization and workflow names for the results
+      // Get organization names for the results
       const db = createDatabase(c.env.DB);
       const orgIds = [...new Set(rows.map((r) => r.index1))];
-      const workflowIds = [...new Set(rows.map((r) => r.blob2))];
 
       // Fetch organization names
       const orgsMap = new Map<string, string>();
@@ -141,15 +140,6 @@ adminExecutionsRoutes.get(
         orgs.forEach((o) => orgsMap.set(o.id, o.name));
       }
 
-      // Fetch workflow names
-      const workflowsMap = new Map<string, string>();
-      if (workflowIds.length > 0) {
-        const wfs = await db
-          .select({ id: workflows.id, name: workflows.name })
-          .from(workflows);
-        wfs.forEach((w) => workflowsMap.set(w.id, w.name));
-      }
-
       const executions = rows.map((row) => {
         const timestamp = new Date(row.timestamp);
         const startedAt = row.double2 ? new Date(row.double2) : timestamp;
@@ -158,7 +148,7 @@ adminExecutionsRoutes.get(
         return {
           id: row.blob1,
           workflowId: row.blob2,
-          workflowName: workflowsMap.get(row.blob2) || "Unknown Workflow",
+          workflowName: row.blob6 || "Unknown Workflow",
           organizationId: row.index1,
           organizationName: orgsMap.get(row.index1) || "Unknown Organization",
           status: row.blob4 as ExecutionStatusType,
@@ -213,14 +203,9 @@ adminExecutionsRoutes.get(
         return c.json({ error: "Execution not found" }, 404);
       }
 
-      // Get workflow and org names
+      // Get org name
       const db = createDatabase(c.env.DB);
 
-      const [workflow] = await db
-        .select({ name: workflows.name })
-        .from(workflows)
-        .where(eq(workflows.id, execution.workflowId));
-
       const [org] = await db
         .select({ name: organizations.name })
         .from(organizations)
@@ -230,7 +215,7 @@ adminExecutionsRoutes.get(
         execution: {
           id: execution.id,
           workflowId: execution.workflowId,
-          workflowName: workflow?.name || "Unknown Workflow",
+          workflowName: execution.workflowName,
           organizationId,
           organizationName: org?.name || "Unknown Organization",
           status: execution.status,

apps/api/src/routes/dashboard.ts

@@ -64,7 +64,7 @@ dashboard.get("/", async (c) => {
     // Recent executions (last 10)
     const recentExecutions = executions.slice(0, 10).map((e: ExecutionRow) => ({
       id: e.id,
-      workflowName: workflows.find((w) => w.id === e.workflowId)?.name || "",
+      workflowName: e.workflowName,
       status: e.status,
       startedAt: e.startedAt ? Number(e.startedAt) : Date.now(),
       endedAt: e.endedAt ? Number(e.endedAt) : undefined,

apps/api/src/routes/executions.ts

@@ -13,7 +13,6 @@ import { ApiContext } from "../context";
 import { createDatabase } from "../db";
 import { feedback } from "../db/schema";
 import { CloudflareExecutionStore } from "../runtime/cloudflare-execution-store";
-import { WorkflowStore } from "../stores/workflow-store";
 import { isUuid, parseUuid } from "../utils/validation";
 
 const executionRoutes = new Hono<ApiContext>();
@@ -36,17 +35,10 @@ executionRoutes.get("/:id", apiKeyOrJwtMiddleware, async (c) => {
       return c.json({ error: "Execution not found" }, 404);
     }
 
-    // Get workflow name
-    const workflowStore = new WorkflowStore(c.env);
-    const workflowName = await workflowStore.getName(
-      execution.workflowId,
-      organizationId
-    );
-
     const workflowExecution: WorkflowExecution = {
       id: execution.id,
       workflowId: execution.workflowId,
-      workflowName: workflowName || "Unknown Workflow",
+      workflowName: execution.workflowName,
       status: execution.status as WorkflowExecutionStatus,
       nodeExecutions: execution.data.nodeExecutions || [],
       error: execution.error || undefined,
@@ -88,7 +80,6 @@ executionRoutes.get("/:id", apiKeyOrJwtMiddleware, async (c) => {
 
 executionRoutes.get("/", jwtMiddleware, async (c) => {
   const executionStore = new CloudflareExecutionStore(c.env);
-  const workflowStore = new WorkflowStore(c.env);
   const { workflowId, limit, offset } = c.req.query();
 
   const organizationId = c.get("organizationId")!;
@@ -108,16 +99,11 @@ executionRoutes.get("/", jwtMiddleware, async (c) => {
 
   const executions = await executionStore.list(organizationId, queryParams);
 
-  // Get workflow names for all executions
-  const workflowIds = [...new Set(executions.map((e) => e.workflowId))];
-  const workflowNames = await workflowStore.getNames(workflowIds);
-  const workflowMap = new Map(workflowNames.map((w) => [w.id, w.name]));
-
   const results = executions.map((execution) => {
     return {
       id: execution.id,
       workflowId: execution.workflowId,
-      workflowName: workflowMap.get(execution.workflowId) || "Unknown Workflow",
+      workflowName: execution.workflowName,
       status: execution.status as WorkflowExecutionStatus,
       error: execution.error || undefined,
       startedAt: execution.startedAt || undefined,

apps/api/src/routes/workflows.ts

@@ -570,6 +570,7 @@ workflowRoutes.post(
       const updatedExecution = await executionStore.save({
         id: executionId,
         workflowId: execution.workflowId,
+        workflowName: execution.workflowName,
         userId: "cancelled", // Required by SaveExecutionRecord but not stored in DB
         organizationId: execution.organizationId,
         status: ExecutionStatus.CANCELLED,
@@ -594,6 +595,7 @@ workflowRoutes.post(
       await executionStore.save({
         id: executionId,
         workflowId: execution.workflowId,
+        workflowName: execution.workflowName,
         userId: "cancelled", // Required by SaveExecutionRecord but not stored in DB
         organizationId: execution.organizationId,
         status: ExecutionStatus.CANCELLED,

apps/api/src/runtime/cloudflare-execution-store.ts

@@ -30,6 +30,7 @@ interface AnalyticsRow {
   blob3: string;
   blob4: string;
   blob5: string;
+  blob6: string;
   double1: number;
   double2: number;
   double3: number;
@@ -61,6 +62,7 @@ export class CloudflareExecutionStore implements ExecutionStore {
     const executionData: WorkflowExecution = {
       id: record.id,
       workflowId: record.workflowId,
+      workflowName: record.workflowName,
       status: record.status,
       nodeExecutions,
       error: record.error,
@@ -166,6 +168,7 @@ export class CloudflareExecutionStore implements ExecutionStore {
           record.definitionHash ?? "",
           record.status,
           (record.error || "").substring(0, 2000), // truncate to fit in blob
+          record.workflowName,
         ],
         doubles: [durationMs, startedAtMs, endedAtMs, usage],
       };
@@ -273,6 +276,10 @@ export class CloudflareExecutionStore implements ExecutionStore {
     return {
       id: executionData.id,
       workflowId: executionData.workflowId,
+      workflowName:
+        executionData.workflowName ??
+        executionData.workflowDefinition?.name ??
+        "Unknown Workflow",
       organizationId,
       status: executionData.status,
       error: executionData.error ?? null,
@@ -326,6 +333,7 @@ export class CloudflareExecutionStore implements ExecutionStore {
         return {
           id: row.blob1,
           workflowId: row.blob2,
+          workflowName: row.blob6 || "Unknown Workflow",
           organizationId: row.index1,
           definitionHash: row.blob3 || undefined,
           status: row.blob4 as WorkflowExecutionStatus,

packages/runtime/src/base-runtime.ts

@@ -472,6 +472,7 @@ export abstract class Runtime<Env = unknown> {
             return this.executionStore.save({
               id: instanceId,
               workflowId: ctx.workflowId,
+              workflowName: ctx.workflow.name,
               userId,
               organizationId,
               status: finalStatus,

packages/runtime/src/execution-store.ts

@@ -11,6 +11,7 @@ import type {
 export interface ExecutionRow {
   id: string;
   workflowId: string;
+  workflowName: string;
   organizationId: string;
   status: WorkflowExecutionStatus;
   error: string | null;
@@ -28,6 +29,7 @@ export interface ExecutionRow {
 export interface SaveExecutionRecord {
   id: string;
   workflowId: string;
+  workflowName: string;
   userId: string;
   organizationId: string;
   status: WorkflowExecutionStatus;