github/sim
1
0
Fork 0
mirror of https://github.com/simstudioai/sim.git synced 2026-01-22 13:28:04 -05:00
Code Issues Packages Projects Releases Wiki Activity

fix(starter): add temp logging to debug executor inability to resolve envvars

Browse Source
This commit is contained in:
Waleed Latif
2025-02-19 13:19:28 -08:00
parent d8f34f1538
commit 47abb35a22
1 changed files with 42 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

44
app/api/scheduled/execute/route.ts
View File

@@ -242,11 +242,31 @@ export async function POST(req: NextRequest) {
Promise.resolve({} as Record<string, Record<string, any>>)
)
// Create a map of decrypted environment variables
const decryptedEnvVars: Record<string, string> = {}
for (const [key, encryptedValue] of Object.entries(variables)) {
try {
const { decrypted } = await decryptSecret(encryptedValue)
decryptedEnvVars[key] = decrypted
} catch (error: any) {
console.error(`Failed to decrypt ${key}:`, error)
throw new Error(`Failed to decrypt environment variable "${key}": ${error.message}`)
}
}
// Add logging for the final block states
console.log('Final block states:', JSON.stringify(currentBlockStates, null, 2))
// Serialize and execute the workflow
const serializedWorkflow = new Serializer().serializeWorkflow(mergedStates, edges, loops)
const executor = new Executor(serializedWorkflow, currentBlockStates, {})
console.log('Serialized workflow:', JSON.stringify(serializedWorkflow, null, 2))
const executor = new Executor(serializedWorkflow, currentBlockStates, decryptedEnvVars)
const executionId = uuidv4()
console.log('Starting execution with ID:', executionId)
const result = await executor.execute(schedule.workflowId)
console.log('Execution result:', result)
// Log the execution result
await persistLog({
@@ -408,11 +428,31 @@ export async function GET(req: NextRequest) {
Promise.resolve({} as Record<string, Record<string, any>>)
)
// Create a map of decrypted environment variables
const decryptedEnvVars: Record<string, string> = {}
for (const [key, encryptedValue] of Object.entries(variables)) {
try {
const { decrypted } = await decryptSecret(encryptedValue)
decryptedEnvVars[key] = decrypted
} catch (error: any) {
console.error(`Failed to decrypt ${key}:`, error)
throw new Error(`Failed to decrypt environment variable "${key}": ${error.message}`)
}
}
// Add logging for the final block states
console.log('Final block states:', JSON.stringify(currentBlockStates, null, 2))
// Serialize and execute the workflow
const serializedWorkflow = new Serializer().serializeWorkflow(mergedStates, edges, loops)
const executor = new Executor(serializedWorkflow, currentBlockStates, {})
console.log('Serialized workflow:', JSON.stringify(serializedWorkflow, null, 2))
const executor = new Executor(serializedWorkflow, currentBlockStates, decryptedEnvVars)
const executionId = uuidv4()
console.log('Starting execution with ID:', executionId)
const result = await executor.execute(schedule.workflowId)
console.log('Execution result:', result)
// Log the execution result
await persistLog({