def _process_failures(self, key):
        '''
        Handles the retrying of the failed key
        '''
        if self.settings['RETRY_FAILURES']:
            self.logger.debug("going to retry failure")
            # get the current failure count
            failkey = self._get_fail_key(key)
            current = self.redis_conn.get(failkey)
            if current is None:
                current = 0
            else:
                current = int(current)
            if current < self.settings['RETRY_FAILURES_MAX']:
                self.logger.debug("Incr fail key")
                current += 1
                self.redis_conn.set(failkey, current)
            else:
                self.logger.error("Could not process action within"
                                  " failure limit")
                self.redis_conn.delete(failkey)
                self.redis_conn.delete(key)
def _process_failures ( self , key ) : if self . settings [ 'RETRY_FAILURES' ] : self . logger . debug ( "going to retry failure" ) failkey = self . _get_fail_key ( key ) current = self . redis_conn . get ( failkey ) if current is None : current = 0 else : current = int ( current ) if current < self . settings [ 'RETRY_FAILURES_MAX' ] : self . logger . debug ( "Incr fail key" ) current += 1 self . redis_conn . set ( failkey , current ) else : self . logger . error ( "Could not process action within" " failure limit" ) self . redis_conn . delete ( failkey ) self . redis_conn . delete ( key )
Handles the retrying of the failed key