def release()

in datafusion_ray/core.py [0:0]

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

    def release(self, processor_keys: list[str]):
        for processor_key in processor_keys:
            self.acquired.remove(processor_key)
            self.available.add(processor_key)