save_order_shipments.py

def save_order_shipments(self, order):
        if not order["shipments"]:
            return

        customer_properties_dict = copy.deepcopy(order["customer"])
        customer_properties = CustomerProperties(
            email=customer_properties_dict.pop(ProfileConstants.EMAIL_KEY)
        )
        customer_properties.set_custom_properties(customer_properties_dict)

        for shipment in order["shipments"]:
            if shipment["State"] == "shipped":
                if not shipment.get("ShippedAt"):
                    continue
                timestamp = dateutil_parse(shipment["ShippedAt"]).astimezone(pytz.utc)

                order_properties = copy.deepcopy(order["properties"])
                order_properties["extra"] = order_properties.pop(EventConstants.EXTRA)

                properties = {
                    EventConstants.EXTRA: {
                        "Shipment": shipment,
                        "Order": order_properties,
                    },
                }

                shipped_order_event = OrderShippedEvent(
                    service=self.service,
                    unique_key=shipment["Id"],
                    customer_properties=customer_properties,
                    event_data=properties,
                    time=timestamp,
                )

                self._publish_event(shipped_order_event)