#NEWLINE# def setUp( self ) : #NEWLINE# #INDENT# self . fs = luigi . contrib . hdfs . get_autoconfig_client ( ) #NEWLINE# cfg_path = os . path . join ( os . path . dirname ( os . path . abspath ( __file__ ) ) , 'testconfig' ) #NEWLINE# hadoop_bin = os . path . join ( os . environ [ 'HADOOP_HOME' ] , 'bin/hadoop' ) #NEWLINE# cmd = '{} --config {}' . format ( hadoop_bin , cfg_path ) #NEWLINE# self . stashed_hdfs_client = luigi . configuration . get_config ( ) . get ( 'hadoop' , 'command' , None ) #NEWLINE# luigi . configuration . get_config ( ) . set ( 'hadoop' , 'command' , cmd )