• Stream of Record is sent as input
• iterable_inputs is created for "Input 1"
• iterate over all records within iterable_inputs
• Within yield, map values from the source schema to match output schema
  • ItemName = record
  • Description = record
  • etc.
• "Output 1" will yield Stream of Records for all records with your mapping applied

def executeNode(inputs):
  iterable_inputs = {}
  outputs = {}
   
  # Input ports
   
  iterable_inputs = inputs
  # Type = stream.record
  # cost, msrp, description, upc, weight, currency, weightUom, productName
   
  # Add node logic here
  for record in iterable_inputs:
    yield {
      "Output 1": {
        "ItemName": record,
        "Description": record,
        "ManagingEntName": record,
        "ManufacturerPrice": record,
        "Price": record,
        "Currency": record,
        "CaseUPC": record,
        "PackageUPC": record,
        "Weight": record,
        "WeightUOM": record,
        "Active": True
      }
    }
   
  # Activate and set outputs (omit a port to prevent execution of nodes that depend on that port)
   
  # Type = stream.record
   
  return outputs