class Multiwoven::Integrations::Destination::Iterable::Client

def initialize_attribute(stream, record)
  if stream.name == "CatalogItems"
    JSON.parse(record[:item_attribute])
  else
    {}
  end
end