Lines Matching full:tasks

25 # The number of tasks to be put in each generation to be tested.
28 # The stride of permutation used to shuffle the input list of tasks. Should be
40   def __init__(self, tasks, next_generations):  argument
44       tasks: A set of tasks to be run.
48     Generation.__init__(self, tasks, None)
64   generation. The steering algorithm should send all the tasks to the next stage
71     """Test that the steering algorithm processes all the tasks properly.
73     Test that the steering algorithm sends all the tasks to the next stage. Test
74     that the steering algorithm terminates once all the tasks have been
75     processed, i.e., the results for the tasks are all ready.
89       # tasks put into a generation.
91       tasks = [IdentifierMockTask(STEERING_TEST_STAGE, t) for t in test_ranges]
92       steering_tasks = set(tasks)
120       tasks = [task for task in generation.Pool()]
122       # Test that all the tasks are processed once and only once.
123       while tasks:
126         assert task in tasks
127         tasks.remove(task)
140     """The steering algorithm returns immediately if there is no new tasks.
142     If all the new tasks have been cached before, the steering algorithm does
143     not have to execute these tasks again and thus can terminate right away.
146     # Put a set of tasks in the cache and add this set to initial generation.
148     tasks = [IdentifierMockTask(STEERING_TEST_STAGE, t) for t in test_ranges]
149     steering_tasks = set(tasks)