任务结果上报 :param job_id: job标识号 :param task_id: 任务标识号 :param node_task_version: 任务版本号 :param code: 任务返回码 :param data_url: 分析结果在文件服务器的地址 :param message: 成功或失败提示信息 :param log_url: 分析日志文件在文件服务器的url :param execute_processes: 执行的任务进程 :
(self, task_params, job_id, task_id, node_task_version, code, data_url, message, log_url, execute_processes)
| 375 | CodeDogHttpClient(self._server_url, rel_url, headers=self._headers).post() |
| 376 | |
| 377 | def send_task_result(self, task_params, job_id, task_id, node_task_version, code, data_url, message, log_url, execute_processes): |
| 378 | """任务结果上报 |
| 379 | |
| 380 | :param job_id: job标识号 |
| 381 | :param task_id: 任务标识号 |
| 382 | :param node_task_version: 任务版本号 |
| 383 | :param code: 任务返回码 |
| 384 | :param data_url: 分析结果在文件服务器的地址 |
| 385 | :param message: 成功或失败提示信息 |
| 386 | :param log_url: 分析日志文件在文件服务器的url |
| 387 | :param execute_processes: 执行的任务进程 |
| 388 | :return:True|False, 上报是否成功 |
| 389 | """ |
| 390 | org_sid = task_params["org_sid"] |
| 391 | team_name = task_params["team_name"] |
| 392 | repo_id = task_params["repo_id"] |
| 393 | project_id = task_params["project_id"] |
| 394 | rel_url = f"api/orgs/{org_sid}/teams/{team_name}/repos/{repo_id}/projects/{project_id}" \ |
| 395 | f"/jobs/{job_id}/tasks/{task_id}/" |
| 396 | # result_msg字段在server上长度限制为256 |
| 397 | if len(message) > 256: |
| 398 | message = message[:256] |
| 399 | data = { |
| 400 | "task_version": node_task_version, |
| 401 | "result_code": code, |
| 402 | "result_data_url": data_url, |
| 403 | "result_msg": message, |
| 404 | "log_url": log_url, |
| 405 | "processes": execute_processes |
| 406 | } |
| 407 | CodeDogHttpClient(self._server_url, rel_url, headers=self._headers, json_data=data).put() |
| 408 | |
| 409 | def get_job_code_line(self, task_params, job_id): |
| 410 | """ |
no test coverage detected