Function createRunProjectCallbacks

packages/cli/src/commands/run.ts:1035–1156

({
  engine,
  isMachineOutput,
  state,
}: {
  engine: ExecutionEngine
  isMachineOutput: boolean
  state: RunExecutionState
})

}

function createRunProjectCallbacks({
  engine,
  isMachineOutput,
  state,
}: {
  engine: ExecutionEngine
  isMachineOutput: boolean
  state: RunExecutionState
}) {
  return {
    onBlockStart: async (block: RuntimeDeepnoteBlock, index: number, total: number) => {
      const label = getBlockLabel(block)
      state.blockLabels.set(block.id, label)

      if (!isMachineOutput) {
        state.agentStreamed = false
        state.agentTextBuffer = ''
        state.reasoningActive = false
        state.activeBlockId = block.id
        const c = getChalk()
        process.stdout.write(`${c.cyan(`[${index + 1}/${total}] ${label}`)} `)
      }

      await captureMemoryBeforeBlock(state, engine, block.id)
    },

    onOutput: (blockId: string, blockOutput: IOutput) => {
      if (isMachineOutput || !state.blockLabels.has(blockId)) {
        return
      }

      if (!state.blocksWithStreamedOutput.has(blockId)) {
        output('')
      }

      renderOutput(blockOutput)
      state.blocksWithStreamedOutput.add(blockId)
    },

    onBlockDone: async (result: BlockExecutionResult) => {
      const label = state.blockLabels.get(result.blockId) ?? result.blockType
      state.blockLabels.delete(result.blockId) // Clean up to avoid memory growth
      state.blockResults.push({
        id: result.blockId,
        type: result.blockType,
        label,
        success: result.success,
        durationMs: result.durationMs,
        outputs: result.outputs,
        error: result.error?.message,
      })

      const memoryDeltaStr = await recordBlockProfile(state, engine, result, label)

      if (!isMachineOutput && (!state.activeBlockId || result.blockId === state.activeBlockId)) {
        const c = getChalk()
        const hadStreamedOutput = state.blocksWithStreamedOutput.delete(result.blockId)
        const prefix = state.agentStreamed || hadStreamedOutput ? '\n' : ''