def abort()

in pyspark_huggingface/huggingface_sink.py [0:0]

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

    def abort(self, messages: List[HuggingFaceCommitMessage]) -> None:  # type: ignore[override]
        # We don't need to do anything here, as the files are not included in the repo until commit
        additions = [addition for message in messages for addition in message.additions]
        for addition in additions:
            logger.info(f"Aborted {addition}")