def METHOD_NAME(self) -> None:
    mock_k8s_client()
    self._job_resource = JobResource()
    self._job_resource.node_group_resources[
        NodeType.WORKER
    ] = NodeGroupResource(5, NodeResource(16, 2048))
    self._elastic_job = new_elastic_job(
        PlatformType.KUBERNETES, "test", "default"
    )
    self._job_nodes = self._job_resource.init_job_node_meta(
        1,
        self._elastic_job.get_node_service_addr,
        self._elastic_job.get_node_name,
    )
    self._worker_manager = WorkerManager(
        self._job_nodes[NodeType.WORKER],
        self._job_resource,
        3,
        self._elastic_job.get_node_service_addr,
        self._elastic_job.get_node_name,
    )