执行单个任务扫描
(self)
| 145 | self.env = env |
| 146 | |
| 147 | def run(self): |
| 148 | """ |
| 149 | 执行单个任务扫描 |
| 150 | """ |
| 151 | log_file = os.path.join(self.task_request['task_dir'], 'task.log') |
| 152 | request_file = os.path.join(self.task_request['task_dir'], 'task_request.json') |
| 153 | response_file = os.path.join(self.task_request['task_dir'], 'task_response.json') |
| 154 | |
| 155 | with open(request_file, 'w') as wf: |
| 156 | json.dump(self.task_request, wf, indent=2) |
| 157 | |
| 158 | # 启动任务 |
| 159 | task = Task(self.task_request['id'], self.task_request['task_name'], |
| 160 | request_file, response_file, log_file, env=self.env) |
| 161 | task.start() |
| 162 | self._running_task.append(task) |
| 163 | |
| 164 | # 等待任务执行完成 |
| 165 | while self._running_task: |
| 166 | time.sleep(10) |
| 167 | self._handle_exist_task() |
| 168 | |
| 169 | return task |
| 170 | |
| 171 | |
| 172 | class InOrderTasksRunner(object): |
no test coverage detected