Function persistCleanedMapping

apps/sim/executor/utils/lazy-cleanup.ts:98–140

* Persist the cleaned inputMapping to the database * * @param workflowId - The workflow ID * @param blockId - The block ID * @param cleanedMapping - The cleaned inputMapping value

(
  workflowId: string,
  blockId: string,
  cleanedMapping: Record<string, any>
)

 * @param cleanedMapping - The cleaned inputMapping value
 */
async function persistCleanedMapping(
  workflowId: string,
  blockId: string,
  cleanedMapping: Record<string, any>
): Promise<void> {
  try {
    await db.transaction(async (tx) => {
      const [block] = await tx
        .select({ subBlocks: workflowBlocks.subBlocks })
        .from(workflowBlocks)
        .where(and(eq(workflowBlocks.id, blockId), eq(workflowBlocks.workflowId, workflowId)))
        .limit(1)

      if (!block) {
        logger.warn(`Block ${blockId} not found in workflow ${workflowId}, skipping persistence`)
        return
      }

      const subBlocks = (block.subBlocks as Record<string, any>) || {}

      if (subBlocks.inputMapping) {
        subBlocks.inputMapping = {
          ...subBlocks.inputMapping,
          value: cleanedMapping,
        }

        // Persist updated subBlocks
        await tx
          .update(workflowBlocks)
          .set({
            subBlocks: subBlocks,
            updatedAt: new Date(),
          })
          .where(and(eq(workflowBlocks.id, blockId), eq(workflowBlocks.workflowId, workflowId)))

        logger.info(`Successfully persisted cleaned inputMapping for block ${blockId}`)
      }
    })
  } catch (error) {
    logger.error('Error persisting cleaned mapping:', error)
    throw error
  }
}