clusterspecgenerator_client.py 文件源码

def register_container(self, application_id, ip, port, job_name, task_index):
        container = csg.Container()
        container.applicationId = application_id
        container.ip = ip
        container.port = port
        container.jobName = job_name
        container.taskIndex = task_index
        request = csg.RegisterContainerRequest(container=container)
        try:
            self.stub.RegisterContainer(request)
        except grpc.RpcError:
            return False
        return True