def stages()

in datafusion_ray/core.py [0:0]

• 8 lines of code
• 2 McCabe index (conditional complexity)

    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