获取任务 :param node_is_free: 当前节点是否空闲 :return: 任务参数信息json;无任务返回空
(self, node_is_free)
| 356 | CodeDogHttpClient(self._server_url, rel_url, headers=self._headers, json_data=data).post() |
| 357 | |
| 358 | def get_task(self, node_is_free): |
| 359 | """ |
| 360 | 获取任务 |
| 361 | :param node_is_free: 当前节点是否空闲 |
| 362 | :return: 任务参数信息json;无任务返回空 |
| 363 | """ |
| 364 | rel_url = "api/jobs/taskqueue/nodes/%s/tasks/register/" % persist_data["NODE_ID"] |
| 365 | data = {"free": node_is_free} |
| 366 | rsp = CodeDogHttpClient(self._server_url, rel_url, headers=self._headers, json_data=data).post() |
| 367 | return self.get_data_from_result(rsp) |
| 368 | |
| 369 | def confirm_task(self, task_id): |
| 370 | """ |
no test coverage detected