odps/mars_extension/legacy/deploy/app.py [180:219]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    rc_name = "gscoordinator"

    def __init__(self, *args, **kwargs):
        if os.environ.get("VM_ENGINE_TYPE") == "hyper":
            default_port = GS_COORDINATOR_GATEWAY_PORT
        else:
            default_port = None
        kwargs["service_port"] = kwargs.get("service_port", None) or default_port
        self._worker_pod_name_list = kwargs.pop("worker_pod_name_list", None)
        self._worker_pod_ip_list = kwargs.pop("worker_pod_ip_list", None)
        self._port = GS_COORDINATOR_PORT
        self._gateway_port = kwargs["service_port"]
        self._worker_num = kwargs.pop("worker_num", 1)
        super().__init__(*args, **kwargs)

    def build_container_command(self):
        # replace command with coordinator
        coordinator_args = dict(
            port=self._port,
            gateway_port=self._gateway_port,
            worker_pod_name_list=self._worker_pod_name_list,
            worker_pod_ip_list=self._worker_pod_ip_list,
            num_workers=self._worker_num,
        )
        cmd = [
            "/srv/entrypoint.sh",
            self.get_local_app_module("gscoordinator"),
            base64.b64encode(json.dumps(coordinator_args).encode()).decode(),
        ]
        return cmd

    def add_default_envs(self):
        super().add_default_envs()
        self.add_env("MARS_POD_ROLE", "gscoordinator")
        if os.environ.get("VM_ENGINE_TYPE") == "hyper":
            self.add_env("GS_COORDINATOR_GATEWAY_PORT", self._container_port)
            self.add_env("GS_COORDINATOR_PORT", self._container_port)


class CupidKubernetesCluster(KubernetesCluster):
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



odps/mars_extension/oscar/deploy/app.py [171:210]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    rc_name = "gscoordinator"

    def __init__(self, *args, **kwargs):
        if os.environ.get("VM_ENGINE_TYPE") == "hyper":
            default_port = GS_COORDINATOR_GATEWAY_PORT
        else:
            default_port = None
        kwargs["service_port"] = kwargs.get("service_port", None) or default_port
        self._worker_pod_name_list = kwargs.pop("worker_pod_name_list", None)
        self._worker_pod_ip_list = kwargs.pop("worker_pod_ip_list", None)
        self._port = GS_COORDINATOR_PORT
        self._gateway_port = kwargs["service_port"]
        self._worker_num = kwargs.pop("worker_num", 1)
        super().__init__(*args, **kwargs)

    def build_container_command(self):
        # replace command with coordinator
        coordinator_args = dict(
            port=self._port,
            gateway_port=self._gateway_port,
            worker_pod_name_list=self._worker_pod_name_list,
            worker_pod_ip_list=self._worker_pod_ip_list,
            num_workers=self._worker_num,
        )
        cmd = [
            "/srv/entrypoint.sh",
            self.get_local_app_module("gscoordinator"),
            base64.b64encode(json.dumps(coordinator_args).encode()).decode(),
        ]
        return cmd

    def add_default_envs(self):
        super().add_default_envs()
        self.add_env("MARS_POD_ROLE", "gscoordinator")
        if os.environ.get("VM_ENGINE_TYPE") == "hyper":
            self.add_env("GS_COORDINATOR_GATEWAY_PORT", self._container_port)
            self.add_env("GS_COORDINATOR_PORT", self._container_port)


class CupidKubernetesCluster(KubernetesCluster):
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -