Data Pipeline In Python