#NEWLINE# def test_write( self ) : #NEWLINE# #INDENT# with open ( osp . join ( self . dpath , 'weather.jsonl' ) ) as reader : #NEWLINE# #INDENT# main ( [ 'write' , 'weather.avro' , '--schema' , dumps ( self . schema ) , '--codec' , 'null' ] , client = self . client , stdin = reader ) #NEWLINE# #UNINDENT# with temppath ( ) as tpath : #NEWLINE# #INDENT# self . client . download ( 'weather.avro' , tpath ) #NEWLINE# eq_ ( self . _get_data_bytes ( tpath ) , self . _get_data_bytes ( osp . join ( self . dpath , 'weather.avro' ) ) )