Function executeGenerateRowsNode

src/nodeExecutor.ts:4699–5426

(
  nodeId: string,
  textValue: string,
  inputData: DBTablesNodeData,
  rawConfig?: unknown,
  executionContext?: FlowExecutionContext,
)

}

async function executeGenerateRowsNode(
  nodeId: string,
  textValue: string,
  inputData: DBTablesNodeData,
  rawConfig?: unknown,
  executionContext?: FlowExecutionContext,
): Promise<NodeExecutionResult> {
  hotPathLog(executionContext, `Generate Rows Node ${nodeId}: Starting execution`);

  // 1. Parse configuration from textValue
  let config: {
    transformations: Array<{
      sourceColumn: string;
      transformationType:
        | "none"
        | "prefix"
        | "suffix"
        | "add"
        | "subtract"
        | "multiply"
        | "divide"
        | "concatenate"
        | "formula"
        | "counter"
        | "counter_range"
        | "filterequal"
        | "filternotequal";
      prefix?: string;
      suffix?: string;
      numericValue?: number;
      startNumber?: number;
      rangeStart?: string; // For counter_range (supports flow options)
      endNumber?: string; // For counter_range (supports flow options)
      rangeIncrement?: string; // For counter_range (supports flow options)
      separator?: string;
      formula?: string;
      filterValue?: string;
      outputColumnName: string;
      targetTableHandleId: string; // Which output table this transformation is for
    }>;
    outputTables: Array<{
      handleId: string;
      name: string;
      existingTableName: string;
      tableVersion?: number;
      columnMapping: string[];
      staticValues?: Record<string, string>;
    }>;
    DBNameToDBVersions?: Record<string, DBVersion[]>;
    customSchemaData?: Array<{ id: string; name: string; type: string }> | null;
  };

  try {
    hotPathLog(executionContext, `Generate Rows Node ${nodeId}: textValue to parse:`, textValue);
    const parsedConfig = getNodeConfig<typeof config>(rawConfig, textValue);
    if (!parsedConfig) {
      throw new Error("Invalid configuration");
    }