#NEWLINE# def save_retry( self , retry_exc ) : #NEWLINE# #INDENT# if ( retry_exc . delay == 0 ) : #NEWLINE# #INDENT# self . requeue ( queue = retry_exc . queue , retry_count = retry_exc . retry_count ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# dateretry = ( datetime . datetime . utcnow ( ) + datetime . timedelta ( seconds = retry_exc . delay ) ) #NEWLINE# updates = { #NEWLINE# #INDENT# 'dateretry' : dateretry , #NEWLINE# 'queue' : retry_exc . queue , #NEWLINE# 'retry_count' : retry_exc . retry_count , #NEWLINE# #UNINDENT# } #NEWLINE# self . _save_status ( 'retry' , retry_exc , exception = True )