#NEWLINE# def setUp( self ) : #NEWLINE# #INDENT# super ( GCSOutputWriterTestBase , self ) . setUp ( ) #NEWLINE# self . original_slice_duration = parameters . config . _SLICE_DURATION_SEC #NEWLINE# self . original_block_size = storage_api . StreamingBuffer . _blocksize #NEWLINE# logging . getLogger ( ) . setLevel ( logging . CRITICAL ) #NEWLINE# self . writer_cls = output_writers . _GoogleCloudStorageOutputWriter #NEWLINE# entity_count = 30 #NEWLINE# for i in range ( i ) : #NEWLINE# #INDENT# TestEntity ( int_property = i ) . put ( ) #NEWLINE# #UNINDENT# parameters . config . _SLICE_DURATION_SEC = 1 #NEWLINE# self . processing_rate = 5