Start all API processes.
(self)
| 1066 | time.sleep(5) |
| 1067 | |
| 1068 | def start(self): |
| 1069 | """Start all API processes.""" |
| 1070 | logger.info(f"Starting {self.num_processes} API processes...") |
| 1071 | |
| 1072 | # Start worker processes |
| 1073 | for i in range(self.num_processes): |
| 1074 | port = self.base_port + i + 1 |
| 1075 | self.start_process(port) |
| 1076 | |
| 1077 | # Start monitoring thread |
| 1078 | monitor_thread = threading.Thread( |
| 1079 | target=self.monitor_processes |
| 1080 | ) |
| 1081 | monitor_thread.daemon = True |
| 1082 | monitor_thread.start() |
| 1083 | |
| 1084 | logger.info("All processes started successfully") |
| 1085 | |
| 1086 | def shutdown(self): |
| 1087 | """Shutdown all processes.""" |