#NEWLINE# def test_write( self ) : #NEWLINE# #INDENT# writer = AvroWriter ( tpath . client , 'weather.avro' , schema = self . schema ) #NEWLINE# with writer : #NEWLINE# #INDENT# for record in self . records : #NEWLINE# #INDENT# writer . write ( record ) #NEWLINE# #UNINDENT# #UNINDENT# with temppath ( ) as tpath : #NEWLINE# #INDENT# self . client . download ( 'weather.avro' , tpath ) #NEWLINE# eq_ ( self . _get_data_bytes ( osp . join ( self . dpath , 'weather.avro' ) ) , self . _get_data_bytes ( tpath ) )