def _get_hadoop_jar()

in src/smspark/bootstrapper.py [0:0]


    def _get_hadoop_jar(self) -> str:
        for file_name in os.listdir(Bootstrapper.HADOOP_PATH):
            if file_name.startswith("hadoop-aws") and file_name.endswith(".jar"):
                self.logger.info(f"Found hadoop jar {file_name}")
                return file_name

        raise AlgorithmError("Error finding hadoop jar", caused_by=FileNotFoundError())