Lines Matching full:tasks

26 # The number of tasks to be put in each generation to be tested.
29 # The stride of permutation used to shuffle the input list of tasks. Should be
41     def __init__(self, tasks, next_generations):  argument
45           tasks: A set of tasks to be run.
49         Generation.__init__(self, tasks, None)
65     generation. The steering algorithm should send all the tasks to the next stage
72         """Test that the steering algorithm processes all the tasks properly.
74         Test that the steering algorithm sends all the tasks to the next stage. Test
75         that the steering algorithm terminates once all the tasks have been
76         processed, i.e., the results for the tasks are all ready.
90             # tasks put into a generation.
92             tasks = [
95             steering_tasks = set(tasks)
126             tasks = [task for task in generation.Pool()]
128             # Test that all the tasks are processed once and only once.
129             while tasks:
132                 assert task in tasks
133                 tasks.remove(task)
146         """The steering algorithm returns immediately if there is no new tasks.
148         If all the new tasks have been cached before, the steering algorithm does
149         not have to execute these tasks again and thus can terminate right away.
152         # Put a set of tasks in the cache and add this set to initial generation.
154         tasks = [
157         steering_tasks = set(tasks)