Function mergeTableSelectionInputs

src/nodeGraphExecutor.ts:207–233

(
  targetIncomingConnections: SerializedConnection[],
  executionResults: Map<string, NodeExecutionResult>,
  nodeMap: Map<string, SerializedNode>,
)

  return sourceResult.data ?? null;
};
const mergeTableSelectionInputs = (
  targetIncomingConnections: SerializedConnection[],
  executionResults: Map<string, NodeExecutionResult>,
  nodeMap: Map<string, SerializedNode>,
) => {
  const mergedSourceFiles: any[] = [];
  const allTables: any[] = [];
  for (const connection of targetIncomingConnections) {
    const sourceData = extractConnectionData(connection, executionResults, nodeMap);
    if (sourceData?.type !== "TableSelection") continue;
    if (sourceData.tables) {
      allTables.push(...sourceData.tables);
    }
    if (sourceData.sourceFiles) {
      mergedSourceFiles.push(...sourceData.sourceFiles);
    }
  }
  if (allTables.length === 0) {
    return null;
  }
  return {
    type: "TableSelection",
    tables: allTables,
    sourceFiles: mergedSourceFiles,
    tableCount: allTables.length,
  };
};
const buildInputDataForTarget = (
  targetNode: SerializedNode,
  targetIncomingConnections: SerializedConnection[],