#NEWLINE# def _handle_commit_response( self , offsets , result ) : #NEWLINE# #INDENT# self . _request_in_flight = False #NEWLINE# if ( result is True ) : #NEWLINE# #INDENT# log . debug ( 'Successfully auto-committed offsets for group %s' , self . _coordinator . group_id ) #NEWLINE# next_at = ( time . time ( ) + self . _interval ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# if ( not isinstance ( result , BaseException ) ) : #NEWLINE# #INDENT# raise Errors . IllegalStateError ( ( 'Unrecognized result in _handle_commit_response: %s' % result ) ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# if ( hasattr ( result , 'retriable' ) and result . retriable ) : #NEWLINE# #INDENT# log . debug ( 'Failed to auto-commit offsets for group %s: %s, will retry immediately' , self . _coordinator . group_id , result ) #NEWLINE# next_at = time . time ( ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# log . warning ( 'Auto offset commit failed for group %s: %s' , self . _coordinator . group_id , result ) #NEWLINE# next_at = ( time . time ( ) + self . _interval ) #NEWLINE# #UNINDENT# #UNINDENT# #UNINDENT# if ( not self . _enabled ) : #NEWLINE# #INDENT# log . warning ( 'Skipping auto-commit reschedule -- it is disabled' ) #NEWLINE# return #NEWLINE# #UNINDENT# self . _reschedule ( next_at )