code: 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(keyf _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)
docs: Handles the retrying of the failed key