in datafusion_ray/core.py [0:0]
def stages(self):
# create our coordinator now, which we need to create stages
if not self._stages:
self._stages = self.df.stages(
self.batch_size,
self.prefetch_buffer_size,
self.partitions_per_processor,
)
return self._stages