#NEWLINE# def testLotsOfEntities( self ) : #NEWLINE# #INDENT# entity_count = 1000 #NEWLINE# for _ in range ( entity_count ) : #NEWLINE# #INDENT# TestEntity ( ) . put ( ) #NEWLINE# #UNINDENT# control . start_map ( 'test_map' , ( __name__ + '.TestHandler' ) , ( input_readers . __name__ + '.DatastoreInputReader' ) , { #NEWLINE# #INDENT# 'entity_kind' : ( ( __name__ + '.' ) + TestEntity . __name__ ) , #NEWLINE# #UNINDENT# } , shard_count = 4 , base_path = '/mapreduce_base_path' ) #NEWLINE# test_support . execute_until_empty ( _ . taskqueue ) #NEWLINE# self . assertEquals ( entity_count , len ( TestHandler . processed_entites ) )