Skip to content
Merged
Next Next commit
fix(env-var-resolution): new executor env var resolution changes
  • Loading branch information
icecrasher321 committed Dec 4, 2025
commit 89fe02b3ddd6c2d635d57bd2a66e4eaf59de5762
6 changes: 5 additions & 1 deletion apps/sim/app/api/workflows/[id]/execute/route.ts
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ const ExecuteWorkflowSchema = z.object({
stream: z.boolean().optional(),
useDraftState: z.boolean().optional(),
input: z.any().optional(),
// Optional workflow state override (for executing diff workflows)
isClientSession: z.boolean().optional(),
workflowStateOverride: z
.object({
blocks: z.record(z.any()),
Expand Down Expand Up @@ -95,6 +95,7 @@ export async function executeWorkflow(
triggerType,
useDraftState: false,
startTime: new Date().toISOString(),
isClientSession: false,
}

const snapshot = new ExecutionSnapshot(
Expand Down Expand Up @@ -329,6 +330,7 @@ export async function POST(req: NextRequest, { params }: { params: Promise<{ id:
stream: streamParam,
useDraftState,
input: validatedInput,
isClientSession = false,
workflowStateOverride,
} = validation.data

Expand Down Expand Up @@ -506,6 +508,7 @@ export async function POST(req: NextRequest, { params }: { params: Promise<{ id:
triggerType,
useDraftState: shouldUseDraftState,
startTime: new Date().toISOString(),
isClientSession,
workflowStateOverride: effectiveWorkflowStateOverride,
}

Expand Down Expand Up @@ -772,6 +775,7 @@ export async function POST(req: NextRequest, { params }: { params: Promise<{ id:
triggerType,
useDraftState: shouldUseDraftState,
startTime: new Date().toISOString(),
isClientSession,
workflowStateOverride: effectiveWorkflowStateOverride,
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,12 +27,12 @@ export async function executeWorkflowWithFullLogging(
const executionId = options.executionId || uuidv4()
const { addConsole } = useTerminalConsoleStore.getState()

// Build request payload
const payload: any = {
input: options.workflowInput,
stream: true,
triggerType: options.overrideTriggerType || 'manual',
useDraftState: true,
isClientSession: true,
}

const response = await fetch(`/api/workflows/${activeWorkflowId}/execute`, {
Expand Down
Loading