Function runDeepnoteProject

packages/cli/src/commands/run.ts:865–950

(path: string | undefined, options: RunOptions)

}

async function runDeepnoteProject(path: string | undefined, options: RunOptions): Promise<void> {
  const { absolutePath, workingDirectory, pythonEnv, inputs, isMachineOutput, convertedFile, file, allIntegrations } =
    await setupProject(path, options)

  debug(`Inputs: ${JSON.stringify(inputs)}`)

  // Apply CLI --input overrides to input block metadata
  applyInputOverrides(file, inputs)

  const state = createRunExecutionState(options, isMachineOutput)
  const engine = new ExecutionEngine({
    pythonEnv,
    workingDirectory,
  })
  const restoreConsoleDebug = suppressMachineOutputDebugNoise(isMachineOutput)
  let engineStarted = false
  let metricsInterval: ReturnType<typeof setInterval> | null = null

  try {
    await startExecutionEngine(engine, isMachineOutput)
    engineStarted = true
    metricsInterval = await startMetricsMonitoring(engine, state.showTop)

    // Track execution timing for snapshot
    const executionStartedAt = new Date().toISOString()
    const blockIds = await resolveUpstreamExecutionBlockIds(file, options, pythonEnv)

    // Use runProject instead of runFile since we may have converted the file in memory
    const summary = await engine.runProject(file, {
      notebookName: options.notebook,
      blockId: options.block,
      blockIds,
      inputs,
      integrations: allIntegrations.map(i => ({ id: i.id, name: i.name, type: i.type })),
      ...createRunProjectCallbacks({ engine, isMachineOutput, state }),
    })

    await saveExecutionSnapshotBestEffort({
      absolutePath,
      convertedFile,
      file,
      blockResults: state.blockResults,
      executionStartedAt,
      isMachineOutput,
    })

    const exitCode = summary.failedBlocks > 0 ? ExitCode.Error : ExitCode.Success

    if (isMachineOutput) {
      const result = await buildMachineRunResult({
        absolutePath,
        file,
        pythonEnv,
        options,
        summary,
        blockResults: state.blockResults,
      })