448013222978734615aaebc8e312f946fdce94fe,python/ray/util/client/server/dataservicer.py,DataServicer,Datapath,#DataServicer#Any#Any#,30

Before Change

                    if self.num_clients == 0 and not ray.is_initialized():
                        self.ray_connect_handler()
                threshold = int(CLIENT_SERVER_MAX_THREADS / 2)
                if self.num_clients >= threshold:
                    context.set_code(grpc.StatusCode.RESOURCE_EXHAUSTED)
                    logger.warning(
                        f"[Data Servicer]: Num clients {self.num_clients} "
                        f"has reached the threshold {threshold}. "
                        f"Rejecting client: {metadata["client_id"]}. ")
                    if log_once("client_threshold"):
                        logger.warning(
                            "You can configure the client connection "
                            "threshold by setting the "
                            "RAY_CLIENT_SERVER_MAX_THREADS env var "
                            f"(currently set to {CLIENT_SERVER_MAX_THREADS}).")
                    return

                self.num_clients += 1
                logger.debug(f"Accepted data connection from {client_id}. "
                             f"Total clients: {self.num_clients}")
                accepted_connection = True
            for req in request_iterator:

After Change

                                 f"Total clients: {self.num_clients}")
                    accepted_connection = True
                else:
                    assert accepted_connection
                    if req_type == "get":
                        get_resp = self.basic_service._get_object(
                            req.get, client_id)
                        resp = ray_client_pb2.DataResponse(get=get_resp)

Instances