in ember/serve.py [0:0]
def _cleanup_expired_processes(self):
"""Background thread to clean up expired processes."""
while True:
current_time = datetime.now()
for model_name in list(self.processes.keys()):
process_info = self.processes[model_name]
if current_time - process_info["start_time"] > timedelta(
minutes=process_info["keep_alive"]
):
logger.info(f"Cleaning up expired process for {model_name}")
self.cleanup_process(model_name)
time.sleep(30)