| 265 | self._no_build_task_requests.append(task_request) |
| 266 | |
| 267 | def prepare_tasks(self, task_request_list): |
| 268 | task_list = [] |
| 269 | for task_request in task_request_list: |
| 270 | log_file = os.path.join(task_request['task_dir'], 'task.log') |
| 271 | request_file = os.path.join(task_request['task_dir'], 'task_request.json') |
| 272 | response_file = os.path.join(task_request['task_dir'], 'task_response.json') |
| 273 | |
| 274 | with open(request_file, 'w') as wf: |
| 275 | json.dump(task_request, wf, indent=2) |
| 276 | |
| 277 | task = Task(task_request['id'], task_request['task_name'], request_file, response_file, log_file, |
| 278 | env=self._env) |
| 279 | task_list.append(task) |
| 280 | return task_list |
| 281 | |
| 282 | def run(self): |
| 283 | task_success = True |