no message

Pyspark_job/yswg_utils/common_udf.py

@@ -802,10 +802,10 @@ def udf_parse_seller_json(seller_json):
         return 0, None, None
     else:
         seller_info_parsed = json.loads(seller_json)
-        ship_from = seller_info_parsed["ship_from"] | None
-        sold_by = seller_info_parsed["sold_by"] | None
-        fulfilled_by = seller_info_parsed["fulfilled_by"] | None
-        seller_id = seller_info_parsed["seller_id"] | None
+        ship_from = seller_info_parsed.get("ship_from", None)
+        sold_by = seller_info_parsed.get("sold_by", None)
+        fulfilled_by = seller_info_parsed.get("fulfilled_by", None)
+        seller_id = seller_info_parsed.get("seller_id", None)
         if (ship_from and ship_from.lower().strip().startswith("amazon")) or (
                 fulfilled_by and 'amazon' in fulfilled_by.lower()):
             if sold_by and not sold_by.lower().strip().startswith("amazon"):