https://github.com/Analyticsphere/pr2-transformation/blob/db66910c2f106a27a9fda71c7c96ae4871ac013d/core/transformations.py#L785-L830 Is this code functional? Implemented end-to-end? Triggered from Airflow?
