def get_sink()

in pyspark_huggingface/huggingface.py [0:0]

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

    def get_sink(self) -> "HuggingFaceSink":
        from pyspark_huggingface.huggingface_sink import HuggingFaceSink

        if self.sink is None:
            self.sink = HuggingFaceSink(self.options.copy())
        return self.sink