RuntimeLineage

Defined in: execution/lineage.ts:62

Complete lineage for a plan execution.

Stores lineage nodes keyed by their AST node ID. Provides a record method for the execution engine to add nodes.

Example

const result = await run(plan, ctx)

// Inspect execution trace
for (const [nodeId, info] of result.lineage.nodes) {
  console.log(`Node ${nodeId}: ${JSON.stringify(info.output)}`)
}

Constructors

Constructor

new RuntimeLineage(): RuntimeLineage

Returns

RuntimeLineage

Properties

nodes

readonly nodes: Map<NodeId, RuntimeLineageNode>

Defined in: execution/lineage.ts:64

Map of node IDs to their lineage information

Methods

record()

record(node): void

Defined in: execution/lineage.ts:73

Record lineage information for a node.

Called by the execution engine as data flows through each node.

Parameters

node

RuntimeLineageNode

The lineage information to record

Returns

void