#NEWLINE# def run( self , filekey , blobkey ) : #NEWLINE# #INDENT# bucket_name = app_identity . get_default_gcs_bucket_name ( ) #NEWLINE# output = ( yield mapreduce_pipeline . MapreducePipeline ( 'index' , 'main.index_map' , 'main.index_reduce' , 'mapreduce.input_readers.BlobstoreZipInputReader' , 'mapreduce.output_writers.GoogleCloudStorageOutputWriter' , mapper_params = { #NEWLINE# #INDENT# 'blob_key' : blobkey , #NEWLINE# #UNINDENT# } , reducer_params = { #NEWLINE# #INDENT# 'output_writer' : { #NEWLINE# #INDENT# 'bucket_name' : bucket_name , #NEWLINE# 'content_type' : 'text/plain' , #NEWLINE# #UNINDENT# } , #NEWLINE# #UNINDENT# } , shards = 16 ) ) #NEWLINE# ( yield StoreOutput ( 'Index' , bucket_name , output ) )