Pipeline data processing - ray.wait vs. ray DAG?

Ray Core
1

How severe does this issue affect your experience of using Ray?

  • Medium: It contributes to significant difficulty to complete my task, but I can work around it.

This example here shows an example of pipeline data processing

Tips for first-time users — Ray 2.7.1

But the Ray DAG (using .bind()) also seems usable in this situation.

Should I prefer ray.wait() over the other?

2

Yea, use ray.wait() for this.