def METHOD_NAME(self):
    params = MockK8sPSJobArgs()
    params.initilize()
    manager = create_job_manager(params, SpeedMonitor())
    manager._init_nodes()
    manager._scaler.scale = mock.MagicMock(return_value=True)
    auto_scaler = PSTrainingAutoScaler(
        manager._job_resource,
        manager._job_nodes,
        manager._job_optimizer,
        manager._speed_monitor,
        manager._ps_manager,
        manager._worker_manager,
        manager._scaler,
    )
    auto_scaler._autoscaling_started = True
    ps0 = manager._ps_manager._nodes[0]
    ps0.config_resource.cpu = 16
    ps0.status = NodeStatus.PENDING
    ps0.create_time = datetime.now() + timedelta(days=-1)
    plan = auto_scaler._reduce_timeout_pending_node_resource()
    self.assertEqual(
        plan.ps_addrs,
        [
            "test-edljob-ps-0.default.svc:2222",
            "test-edljob-ps-1.default.svc:2222",
            "test-edljob-ps-2.default.svc:2222",
        ],
    )