code: def find_item(self):
          '''
          Finds an item from the throttled queues
          '''
          random.shuffle(self.queue_keys)
          count = 0
  
          while count <= self.item_retries:
              for key in self.queue_keys:
                  # skip if the whole domain has been blacklisted in zookeeper
                  if key.split(':')[1] in self.black_domains:
                      continue
                  # the throttled queue only returns an item if it is allowed
                  item = self.queue_dict[key][0].pop()
  
                  if item:
                      # update timeout and return
                      self.queue_dict[key][1] = time.time()
                      return item
  
              count = count + 1
  
          return Nonf find_item(self):
          '''
          Finds an item from the throttled queues
          '''
          random.shuffle(self.queue_keys)
          count = 0
  
          while count <= self.item_retries:
              for key in self.queue_keys:
                  # skip if the whole domain has been blacklisted in zookeeper
                  if key.split(':')[1] in self.black_domains:
                      continue
                  # the throttled queue only returns an item if it is allowed
                  item = self.queue_dict[key][0].pop()
  
                  if item:
                      # update timeout and return
                      self.queue_dict[key][1] = time.time()
                      return item
  
              count = count + 1
  
          return None
docs: Finds an item from the throttled queues