Lines Matching refs:task_queue
62 task_queue = drone_task_queue.DroneTaskQueue()
63 task_queue.results[drone1] = None
65 task_queue.execute, [])
66 task_queue.results.clear()
82 task_queue.execute(drones, wait=False)
83 self.assertTrue(set(task_queue.results.keys()) == set(drones))
84 results = task_queue.get_results()
85 self.assertTrue(len(task_queue.results) == 0)
97 self.assertTrue(task_queue.execute(drones, wait=True)[drone1] ==
99 self.assertTrue(len(task_queue.results) == 0)
100 self.assertTrue(len(task_queue.get_results()) == 0)