def _new_processor()

in datafusion_ray/core.py [0:0]

• 10 lines of code
• 1 McCabe index (conditional complexity)

    def _new_processor(self):
        self.processors_ready.clear()
        processor_key = new_friendly_name()
        log.debug(f"starting processor: {processor_key}")
        processor = DFRayProcessor.options(
            name=f"Processor : {processor_key}"
        ).remote(processor_key)
        self.pool[processor_key] = processor
        self.processors_started.add(processor.start_up.remote())
        self.available.add(processor_key)