Function wrappedOnBlockStart

apps/sim/lib/workflows/executor/execution-core.ts:582–628

(
      blockId: string,
      blockName: string,
      blockType: string,
      executionOrder: number,
      iterationContext?: IterationContext,
      childWorkflowContext?: ChildWorkflowContext
    )

    }

    const wrappedOnBlockStart = (
      blockId: string,
      blockName: string,
      blockType: string,
      executionOrder: number,
      iterationContext?: IterationContext,
      childWorkflowContext?: ChildWorkflowContext
    ) => {
      let persistenceSucceeded = false
      const persistencePromise = (async () => {
        await loggingSession.onBlockStart(blockId, blockName, blockType, new Date().toISOString())
        persistenceSucceeded = true
      })().catch((error) => {
        logger.warn(`[${requestId}] Block start persistence failed`, {
          executionId,
          blockId,
          blockType,
          error,
        })
      })

      const lifecyclePromise = (async () => {
        await persistencePromise
        if (!persistenceSucceeded || !onBlockStart) return

        try {
          await onBlockStart(
            blockId,
            blockName,
            blockType,
            executionOrder,
            iterationContext,
            childWorkflowContext
          )
        } catch (error) {
          logger.warn(`[${requestId}] Block start callback failed`, {
            executionId,
            blockId,
            blockType,
            error,
          })
        }
      })()

      trackLifecycleCallback(lifecyclePromise)
      return persistencePromise
    }

    const largeValueExecutionIds = Array.from(
      new Set(