improvement(executor): parallelize the execution-core serial front

The PII-redaction row read (workspace ⋈ organization) joins the existing
state + environment Promise.all instead of running serially after logging
start, and eligibleOrgForWorkspace resolves its feature-flag and
enterprise-plan reads concurrently after the workspace lookup. Identical
results; fewer serial round trips for every execution path, including
Trigger.dev workers.

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>

Author: icecrasher321

apps/sim/lib/workflows/custom-blocks/operations.ts

@@ -38,11 +38,11 @@ async function eligibleOrgForWorkspace(
 ): Promise<string | null> {
   const ws = await getWorkspaceWithOwner(workspaceId, { includeArchived: true })
   if (!ws?.organizationId) return null
-  if (!(await isFeatureEnabled('deploy-as-block', { userId, orgId: ws.organizationId }))) {
-    return null
-  }
-  if (!(await isOrganizationOnEnterprisePlan(ws.organizationId))) return null
-  return ws.organizationId
+  const [flagEnabled, onEnterprisePlan] = await Promise.all([
+    isFeatureEnabled('deploy-as-block', { userId, orgId: ws.organizationId }),
+    isOrganizationOnEnterprisePlan(ws.organizationId),
+  ])
+  return flagEnabled && onEnterprisePlan ? ws.organizationId : null
 }
 
 /**

apps/sim/lib/workflows/executor/execution-core.ts

@@ -525,9 +525,25 @@ async function executeWorkflowCoreImpl(
       }
     }
 
-    const [workflowState, env] = await Promise.all([
+    /**
+     * Resolves the org/workspace PII redaction row once for this run; serves both
+     * the input stage and the block-outputs stage (threaded into the executor).
+     * Depends only on the workspace id, so it loads alongside the state and env.
+     */
+    const loadPiiRedactionRow = async () => {
+      const [row] = await db
+        .select({ orgSettings: organization.dataRetentionSettings })
+        .from(workspace)
+        .leftJoin(organization, eq(organization.id, workspace.organizationId))
+        .where(eq(workspace.id, providedWorkspaceId))
+        .limit(1)
+      return row
+    }
+
+    const [workflowState, env, piiRedactionRow] = await Promise.all([
       loadWorkflowState(),
       getExecutionEnvironment(personalEnvUserId, workspaceEnvUserId, providedWorkspaceId),
+      loadPiiRedactionRow(),
     ])
 
     const { blocks, loops, parallels } = workflowState
@@ -810,22 +826,14 @@ async function executeWorkflowCoreImpl(
       allowLargeValueWorkflowScope,
     })
 
-    // Resolve the org/workspace PII redaction policy once; serves both the input
-    // stage (below) and the block-outputs stage (threaded into the executor).
-    // Resolved from stored rules UNCONDITIONALLY — deliberately NOT gated on the
-    // `pii-redaction` feature flag. The flag gates configuration (the settings
-    // route); a transient/false flag read at execution time would skip masking
-    // and leak PII (fail-open). Stored rules are only writable by entitled orgs,
-    // so their presence is the source of truth; absence yields the disabled
-    // default (one indexed lookup, no masking cost for non-PII orgs).
-    const [row] = await db
-      .select({ orgSettings: organization.dataRetentionSettings })
-      .from(workspace)
-      .leftJoin(organization, eq(organization.id, workspace.organizationId))
-      .where(eq(workspace.id, providedWorkspaceId))
-      .limit(1)
+    // The policy applies from stored rules UNCONDITIONALLY — deliberately NOT
+    // gated on the `pii-redaction` feature flag. The flag gates configuration
+    // (the settings route); a transient/false flag read at execution time would
+    // skip masking and leak PII (fail-open). Stored rules are only writable by
+    // entitled orgs, so their presence is the source of truth; absence yields
+    // the disabled default (one indexed lookup, no masking cost for non-PII orgs).
     const piiRedaction: EffectivePiiRedaction = resolveEffectivePiiRedaction({
-      orgSettings: row?.orgSettings,
+      orgSettings: piiRedactionRow?.orgSettings,
       workspaceId: providedWorkspaceId,
     })