执行单个任务类
| 130 | |
| 131 | |
| 132 | class SingleTaskRuner(TaskRunner): |
| 133 | """ |
| 134 | 执行单个任务类 |
| 135 | """ |
| 136 | def __init__(self, task_request, env): |
| 137 | """ |
| 138 | 构造函数 |
| 139 | :param task_request: task执行参数 |
| 140 | :param env: task执行的环境变量 |
| 141 | :return: |
| 142 | """ |
| 143 | TaskRunner.__init__(self) |
| 144 | self.task_request = task_request |
| 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 outgoing calls
no test coverage detected