任务进度信息上报 :param node_id: 节点标识号 :param job_id: 项目标识号 :param task_id: 任务标识号 :param message: str, 进度信息 :param percent: int, 进度百分比 :return:
(self, task_params, node_id, message, percent)
| 62 | CodeDogHttpClient(self._server_url, rel_url, headers=self._headers).post() |
| 63 | |
| 64 | def update_task_progress(self, task_params, node_id, message, percent): |
| 65 | """任务进度信息上报 |
| 66 | |
| 67 | :param node_id: 节点标识号 |
| 68 | :param job_id: 项目标识号 |
| 69 | :param task_id: 任务标识号 |
| 70 | :param message: str, 进度信息 |
| 71 | :param percent: int, 进度百分比 |
| 72 | :return: |
| 73 | """ |
| 74 | rel_url = "api/orgs/%s/teams/%s/repos/%s/projects/%s/" \ |
| 75 | "jobs/%s/tasks/%s/progresses/" % (task_params["org_sid"], |
| 76 | task_params["team_name"], |
| 77 | task_params["repo_id"], |
| 78 | task_params["project_id"], |
| 79 | task_params["job_id"], |
| 80 | task_params["task_id"]) |
| 81 | data = { |
| 82 | "message": message, |
| 83 | "progress_rate": percent, |
| 84 | "task": task_params["task_id"], |
| 85 | "node": node_id |
| 86 | } |
| 87 | CodeDogHttpClient(self._server_url, rel_url, headers=self._headers, json_data=data).post() |
| 88 | |
| 89 | # ------------------------------------------------------------------------------------- # |
| 90 | # 格式: ``orgs/<org_sid>/teams/<team_name>/repos/<repo_id>/`` |
nothing calls this directly
no test coverage detected