Function wrappedOnBlockComplete

apps/sim/lib/workflows/executor/execution-core.ts:528–580

(
      blockId: string,
      blockName: string,
      blockType: string,
      output: {
        input?: unknown
        output: NormalizedBlockOutput
        executionTime: number
        startedAt: string
        endedAt: string
      },
      iterationContext?: IterationContext,
      childWorkflowContext?: ChildWorkflowContext
    )

    }

    const wrappedOnBlockComplete = (
      blockId: string,
      blockName: string,
      blockType: string,
      output: {
        input?: unknown
        output: NormalizedBlockOutput
        executionTime: number
        startedAt: string
        endedAt: string
      },
      iterationContext?: IterationContext,
      childWorkflowContext?: ChildWorkflowContext
    ) => {
      let persistenceSucceeded = false
      const persistencePromise = (async () => {
        await loggingSession.onBlockComplete(blockId, blockName, blockType, output)
        persistenceSucceeded = true
      })().catch((error) => {
        logger.warn(`[${requestId}] Block completion persistence failed`, {
          executionId,
          blockId,
          blockType,
          error,
        })
      })

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

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

      trackLifecycleCallback(lifecyclePromise)
      return persistencePromise
    }

    const wrappedOnBlockStart = (
      blockId: string,