Skip to content

Commit 89fe02b

Browse files
committed
fix(env-var-resolution): new executor env var resolution changes
1 parent 9df87d9 commit 89fe02b

11 files changed

Lines changed: 387 additions & 592 deletions

File tree

apps/sim/app/api/workflows/[id]/execute/route.ts

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ const ExecuteWorkflowSchema = z.object({
3434
stream: z.boolean().optional(),
3535
useDraftState: z.boolean().optional(),
3636
input: z.any().optional(),
37-
// Optional workflow state override (for executing diff workflows)
37+
isClientSession: z.boolean().optional(),
3838
workflowStateOverride: z
3939
.object({
4040
blocks: z.record(z.any()),
@@ -95,6 +95,7 @@ export async function executeWorkflow(
9595
triggerType,
9696
useDraftState: false,
9797
startTime: new Date().toISOString(),
98+
isClientSession: false,
9899
}
99100

100101
const snapshot = new ExecutionSnapshot(
@@ -329,6 +330,7 @@ export async function POST(req: NextRequest, { params }: { params: Promise<{ id:
329330
stream: streamParam,
330331
useDraftState,
331332
input: validatedInput,
333+
isClientSession = false,
332334
workflowStateOverride,
333335
} = validation.data
334336

@@ -506,6 +508,7 @@ export async function POST(req: NextRequest, { params }: { params: Promise<{ id:
506508
triggerType,
507509
useDraftState: shouldUseDraftState,
508510
startTime: new Date().toISOString(),
511+
isClientSession,
509512
workflowStateOverride: effectiveWorkflowStateOverride,
510513
}
511514

@@ -772,6 +775,7 @@ export async function POST(req: NextRequest, { params }: { params: Promise<{ id:
772775
triggerType,
773776
useDraftState: shouldUseDraftState,
774777
startTime: new Date().toISOString(),
778+
isClientSession,
775779
workflowStateOverride: effectiveWorkflowStateOverride,
776780
}
777781

apps/sim/app/workspace/[workspaceId]/w/[workflowId]/utils/workflow-execution-utils.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,12 +27,12 @@ export async function executeWorkflowWithFullLogging(
2727
const executionId = options.executionId || uuidv4()
2828
const { addConsole } = useTerminalConsoleStore.getState()
2929

30-
// Build request payload
3130
const payload: any = {
3231
input: options.workflowInput,
3332
stream: true,
3433
triggerType: options.overrideTriggerType || 'manual',
3534
useDraftState: true,
35+
isClientSession: true,
3636
}
3737

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

0 commit comments

Comments
 (0)