#NEWLINE# @ pytest . mark . parametrize ( 'fmt' , [ fmt for fmt in cfiles ] ) #NEWLINE# def test_compression_binary( fmt ) : #NEWLINE# #INDENT# from dask.bytes.core import open_files #NEWLINE# files2 = valmap ( compression . compress [ fmt ] , files ) #NEWLINE# with filetexts ( files2 , mode = 'b' ) : #NEWLINE# #INDENT# myfiles = open_files ( '.test.accounts.*' , compression = fmt ) #NEWLINE# data = compute ( * [ file . read ( ) for file in myfiles ] ) #NEWLINE# assert ( list ( data ) == [ files [ k ] for k in sorted ( files ) ] )