Skip to content

Commit 1617880

Browse files
Vikhyath MondretiVikhyath Mondreti
authored andcommitted
restore workflow handler file
1 parent a429a3a commit 1617880

File tree

1 file changed

+10
-14
lines changed

1 file changed

+10
-14
lines changed

apps/sim/executor/handlers/workflow/workflow-handler.ts

Lines changed: 10 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,4 @@
11
import { createLogger } from '@/lib/logs/console-logger'
2-
import { loadWorkflowFromNormalizedTables } from '@/lib/workflows/db-helpers'
32
import type { BlockOutput } from '@/blocks/types'
43
import { Serializer } from '@/serializer'
54
import type { SerializedBlock } from '@/serializer/types'
@@ -146,24 +145,21 @@ export class WorkflowBlockHandler implements BlockHandler {
146145

147146
logger.info(`Loaded child workflow: ${workflowData.name} (${workflowId})`)
148147

149-
// Load workflow data from normalized tables (like other execution routes do)
150-
logger.debug(`Loading child workflow ${workflowId} from normalized tables`)
151-
const normalizedData = await loadWorkflowFromNormalizedTables(workflowId)
148+
// Extract the workflow state
149+
const workflowState = workflowData.state
152150

153-
if (!normalizedData) {
154-
logger.error(`Child workflow ${workflowId} has no normalized data`)
151+
if (!workflowState || !workflowState.blocks) {
152+
logger.error(`Child workflow ${workflowId} has invalid state`)
155153
return null
156154
}
157155

158-
// Use normalized data only (no fallback to deprecated state column)
159-
const blocks = normalizedData.blocks
160-
const edges = normalizedData.edges
161-
const loops = normalizedData.loops
162-
const parallels = normalizedData.parallels
163-
logger.info(`Loaded child workflow ${workflowId} from normalized tables`)
164-
165156
// Use blocks directly since DB format should match UI format
166-
const serializedWorkflow = this.serializer.serializeWorkflow(blocks, edges, loops, parallels)
157+
const serializedWorkflow = this.serializer.serializeWorkflow(
158+
workflowState.blocks,
159+
workflowState.edges || [],
160+
workflowState.loops || {},
161+
workflowState.parallels || {}
162+
)
167163

168164
return {
169165
name: workflowData.name,

0 commit comments

Comments
 (0)