#NEWLINE# def iget_batches( task_ids , batch_size = 10 ) : #NEWLINE# #INDENT# 'Yield out a map of the keys and futures in batches of the batch size\n    passed in.\n    ' #NEWLINE# make_key = ( lambda _id : ndb . Key ( FuriousAsyncMarker , _id ) ) #NEWLINE# for keys in i_batch ( imap ( make_key , make_key ) , batch_size ) : #NEWLINE# #INDENT# ( yield izip ( keys , ndb . get_multi_async ( keys ) ) )