#NEWLINE# def get_next_requests( self , max_next_requests , **kwargs ) : #NEWLINE# #INDENT# partitions = kwargs . pop ( 'partitions' , [ 0 ] ) #NEWLINE# batch = [ ] #NEWLINE# for partition_id in partitions : #NEWLINE# #INDENT# batch . extend ( self . queue . get_next_requests ( max_next_requests , partition_id , ** kwargs ) ) #NEWLINE# #UNINDENT# return batch