(self)
| 474 | |
| 475 | # 真正执行启动的逻辑 |
| 476 | def real_run_start(self): |
| 477 | pid_file = "{}/{}.pid".format(Group.GROUP_TMP_DIR, self.group_id) |
| 478 | pid = os.getpid() |
| 479 | public.writeFile(pid_file, str(pid)) |
| 480 | if not self.can_running(): |
| 481 | self.running_data["msg"] = "项目组配置文件错误，无法启动该项目组" |
| 482 | self.running_data["status"] = False |
| 483 | self.save_running_data() |
| 484 | return |
| 485 | |
| 486 | # 构建运行启动的信息，并返回运行顺序 |
| 487 | self.running_data["msg"] = "启动操作运行中" |
| 488 | run_sort = self.build_run_sort(reverse=False) |
| 489 | self.save_running_data() |
| 490 | for idx, g in enumerate(run_sort): |
| 491 | res_msg = self._run_start_one_step(g, sort_idx=idx) |
| 492 | if isinstance(res_msg, str): |
| 493 | self.running_data["msg"] = res_msg |
| 494 | self.running_data["status"] = False |
| 495 | self.save_running_data() |
| 496 | return |
| 497 | |
| 498 | self.running_data["msg"] = "启动操作运行成功" |
| 499 | self.running_data["status"] = True |
| 500 | self.save_running_data() |
| 501 | |
| 502 | def save_running_data(self): |
| 503 | log_file = "{}/{}.log".format(Group.GROUP_TMP_DIR, self.group_id) |
no test coverage detected