5cfa1934e4a2157d07ef534e1033a3f0e5bc1082,python/ray/experimental/client/server/server.py,RayletServicer,_schedule_method,#RayletServicer#Any#Any#Any#,164

Before Change

            raise Exception(
                "Can"t run an actor the server doesn"t have a handle for")
        arglist = _convert_args(task.args, prepared_args)
        with stash_api_for_tests(self._test_mode):
            output = getattr(actor_handle, task.name).remote(*arglist)
            self.object_refs[output.binary()] = output
            pickled_ref = cloudpickle.dumps(output)
        return ray_client_pb2.ClientTaskTicket(
            return_ref=make_remote_ref(output.binary(), pickled_ref))

    def _schedule_actor(self,

After Change

                "Can"t run an actor the server doesn"t have a handle for")
        arglist = self._convert_args(task.args, prepared_args)
        output = getattr(actor_handle, task.name).remote(*arglist)
        self.object_refs[task.client_id][output.binary()] = output
        return ray_client_pb2.ClientTaskTicket(return_id=output.binary())

    def _schedule_actor(self,

Instances