# Ray自动处理故障
@ray.remote(max_retries=3)
class FaultTolerantWorker:
    def __init__(self):
        self.model = load_model()
    
    def inference(self, data):
        # 如果worker崩溃，Ray会自动重启
        return self.model.generate(data)