def get_scalding_core(self):
    lib_dir = os.path.join(self.scalding_home, 'lib')
    for j in os.listdir(lib_dir):
        if j.startswith('scalding-core-'):
            p = os.path.join(lib_dir, j)
            logger.debug('Found scalding-core: %s', p)
            return p
    raise luigi.contrib.hadoop.HadoopJobError('Could not find scalding-core.')
def get_scalding_core(self):
    lib_dir = os.path.join(self.scalding_home, 'lib')
    for j in os.listdir(lib_dir):
        if j.startswith('scalding-core-'):
            p = os.path.join(lib_dir, j)
            logger.debug('Found scalding-core: %s', p)
            return p
    raise luigi.contrib.hadoop.HadoopJobError('Could not find scalding-core.')