class ProductTypePipeline:
    def process_item(self, item, spider):
        adapter = ItemAdapter(item)
        if adapter['productType'] is None:
            raise DropItem(f"{adapter['publicName']} has a invalid Product Type and was dropped from Database")
        return item