#NEWLINE# def remove_by_scores( self , scores ) : #NEWLINE# #INDENT# key = self . get_key ( ) #NEWLINE# results = [ ] #NEWLINE# def _remove_many( redis , scores ) : #NEWLINE# #INDENT# for score in scores : #NEWLINE# #INDENT# logger . debug ( 'removing score %s from %s' , score , key ) #NEWLINE# result = redis . zremrangebyscore ( key , score , score ) #NEWLINE# results . append ( result ) #NEWLINE# #UNINDENT# return results #NEWLINE# #UNINDENT# results = self . _pipeline_if_needed ( _remove_many , scores ) #NEWLINE# return results