Restore user-table plan lookup in ExecutionManager for manual/WebSocket execution

The ExecutionManager handles manual execution via WebSocket where a real userId
is available. The user's plan in the users table may differ from what
resolveUserPlan derives from org subscription status (e.g. trialing orgs with
pro users), so the DB lookup is the correct fallback here.

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

Author: bchapuis

apps/api/src/services/execution-manager.ts

@@ -7,13 +7,11 @@
 
 import type { BlobParameter } from "@dafthunk/runtime";
 import type { WorkflowExecution, WorkflowState } from "@dafthunk/types";
+import { eq } from "drizzle-orm";
 import type { Bindings } from "../context";
 import { createDatabase } from "../db/index";
-import {
-  getOrganization,
-  getOrganizationBillingInfo,
-  resolveUserPlan,
-} from "../db/queries";
+import { getOrganization, getOrganizationBillingInfo } from "../db/queries";
+import { users } from "../db/schema";
 import {
   WorkflowExecutor,
   type WorkflowExecutorParameters,
@@ -57,8 +55,16 @@ export class ExecutionManager {
     }
     const { computeCredits, subscriptionStatus, overageLimit } = billingInfo;
 
-    // Resolve user plan from org billing info if not provided
-    const resolvedUserPlan = userPlan || resolveUserPlan(billingInfo);
+    // Get user's plan if not provided (e.g., for WebSocket-based execution)
+    let resolvedUserPlan = userPlan;
+    if (!resolvedUserPlan) {
+      const [user] = await db
+        .select({ plan: users.plan })
+        .from(users)
+        .where(eq(users.id, userId))
+        .limit(1);
+      resolvedUserPlan = user?.plan;
+    }
 
     validateWorkflowForExecution(state);