How can I create data transform pipelines with Ray?

Hello, I was reading the Learning Ray Flexible Distributed Python for Machine Learning, and the code does not work, how can I do it in recent versions of Ray?
2

Can you link to the example you’re referencing so we can see the complete code @nimito ?