5cfa1934e4a2157d07ef534e1033a3f0e5bc1082,python/ray/experimental/client/server/server.py,RayletServicer,GetObject,#RayletServicer#Any#Any#,86

Before Change

        return ray_client_pb2.TerminateResponse(ok=True)

    def GetObject(self, request, context=None):
        request_ref = cloudpickle.loads(request.handle)
        if request_ref.binary() not in self.object_refs:
            return ray_client_pb2.GetResponse(valid=False)
        objectref = self.object_refs[request_ref.binary()]
        logger.info("get: %s" % objectref)

After Change

        return ray_client_pb2.TerminateResponse(ok=True)

    def GetObject(self, request, context=None):
        return self._get_object(request, "", context)

    def _get_object(self, request, client_id: str, context=None):
        if request.id not in self.object_refs[client_id]:
            return ray_client_pb2.GetResponse(valid=False)

Instances