Searched refs:request_queue (Results 1 – 5 of 5) sorted by relevance
39 self.request_queue = []44 self.request_queue.append(self.request(**kwargs).get_request())56 if not self.request_queue:60 result = self.api_call(self.request_queue)61 requests = self.request_queue62 self.request_queue = []
47 request = self.get_hosts_manager.request_queue[0]68 request_1 = self.get_hosts_manager.request_queue[0]69 request_2 = self.get_hosts_manager.request_queue[1]108 self.handler.batch_get_hosts(self.get_hosts_manager.request_queue)120 self.handler.update_hosts(self.update_manager.request_queue)132 self.handler.update_hosts(self.update_manager.request_queue)144 self.handler.update_hosts(self.update_manager.request_queue)156 self.handler.update_hosts(self.update_manager.request_queue)178 exception_types, self.update_manager.request_queue):183 for request in self.update_manager.request_queue:
74 def verify_priority(request_queue, result): argument75 requests = AssignmentValidator.sort_requests(request_queue)110 result = request_manager.api_call(request_manager.request_queue)114 request_manager.request_queue, result)423 result = request_manager.api_call(request_manager.request_queue)476 if any([request for request in request_manager.request_queue487 disorderly_queue = sorted(request_manager.request_queue,489 request_manager.request_queue = disorderly_queue490 result = request_manager.api_call(request_manager.request_queue)
54 request_queue, argument77 self._request_queue = request_queue
102 self.request_queue = Queue.Queue()132 if not self.request_queue.empty():154 while not self.request_queue.empty():157 request = self.request_queue.get()274 self.request_queue.put(request)