def check()

in custom_image_cli/validation_tool/validation_tests/check_local_job_run.py [0:0]

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

    def check(self):
        try:
            print('... Start Running Sample Spark Job')
            command = ['bash', 'spark-submit ' \
                               '--deploy-mode client ' \
                               '--master local ' \
                               '--class org.apache.spark.examples.SparkPi ' + self.entry_point]
            self.docker_cmd.docker_run(self.image_uri, command)
        except ContainerError:
            self.log.error('Sample Spark Job Test with %s : FAIL' % self.entry_point)
            return False
        self.log.info('Sample Spark Job Test with %s : PASS' % self.entry_point)
        return True