Lines Matching refs:drone

58     def worker(drone, results_queue):  argument
68         logging.info('(Worker.%s) starting.', drone.hostname)
70             drone, drone.execute_queued_calls()))
71         logging.info('(Worker.%s) finished.', drone.hostname)
89         for drone, thread in self.drone_threads.iteritems():
94                 drone_exceptions.append((drone, thread.err))
100         for drone, err in drone_exceptions:
102                               (drone.hostname, err))
119             if drone_results.drone in results:
122                         (drone_results.drone, results))
123             results[drone_results.drone] = drone_results.results
151         for drone in drones:
152             if not drone.get_calls():
156                     args=(drone, self.results_queue))
161             self.drone_threads[drone] = worker_thread
164                                   (self.name, drone.hostname.replace('.', '_')))