Lines Matching refs:stage
4 """The pipeline_worker functions of the build and test stage of the framework.
21 def Helper(stage, done_dict, helper_queue, completed_queue, result_queue):
30 stage: The current stage of the pipeline, for example, build stage or test
31 stage.
43 the duplicate tasks will be sent to the next stage via this queue.
59 assert not task.Done(stage)
62 identifier = task.GetIdentifier(stage)
71 task.SetResult(stage, done_dict[identifier])
77 GetResultFromCompletedQueue(stage, completed_queue, done_dict, waiting_list,
82 GetResultFromCompletedQueue(stage, completed_queue, done_dict, waiting_list,
86 def GetResultFromCompletedQueue(stage, completed_queue, done_dict, waiting_list,
91 stage: The current stage of the pipeline, for example, build stage or test
92 stage.
102 the duplicate tasks will be sent to the next stage via this queue.
114 tasks = [t for t in waiting_list if t.GetIdentifier(stage) == identifier]
116 duplicate_task.SetResult(stage, result)
121 def Worker(stage, task, helper_queue, result_queue):
125 to the helper and the next stage.
128 stage: The current stage of the pipeline, for example, build stage or test
129 stage.
134 the communication channel between the worker and the next stage.
138 assert not task.Done(stage)
140 task.Work(stage)
141 helper_queue.put((task.GetIdentifier(stage), task.GetResult(stage)))
