Function continueCascadeAfterResume

apps/sim/background/resume-execution.ts:321–347

(cellContext: {
  tableId: string
  rowId: string
  workspaceId: string
  groupId: string
})

}

async function continueCascadeAfterResume(cellContext: {
  tableId: string
  rowId: string
  workspaceId: string
  groupId: string
}): Promise<void> {
  const { getTableById } = await import('@/lib/table/service')
  const { getRowById } = await import('@/lib/table/rows/service')
  const { pickNextEligibleGroupForRow } = await import('@/lib/table/workflow-columns')
  const { runRowCascadeLoop } = await import('@/background/workflow-column-execution')

  const freshTable = await getTableById(cellContext.tableId)
  if (!freshTable) return
  const freshRow = await getRowById(cellContext.tableId, cellContext.rowId, cellContext.workspaceId)
  if (!freshRow) return
  const next = pickNextEligibleGroupForRow(freshTable, freshRow, cellContext.groupId)
  if (!next) return
  await runRowCascadeLoop({
    tableId: cellContext.tableId,
    tableName: freshTable.name,
    rowId: cellContext.rowId,
    workspaceId: cellContext.workspaceId,
    groupId: next.id,
    workflowId: next.workflowId,
    executionId: generateId(),
  })
}

export const resumeExecutionTask = task({
  id: 'resume-execution',