b7f246c4516fa726c6f7ae8b5d1dac206cdb77d5,python/ray/experimental/client/server/server.py,RayletServicer,_schedule_method,#RayletServicer#Any#Any#Any#,93

Before Change

        with stash_api_for_tests(self._test_mode):
            output = getattr(actor_handle, task.name).remote(*arglist)
            self.object_refs[output.binary()] = output
        return ray_client_pb2.ClientTaskTicket(return_id=output.binary())

    def _schedule_actor(self,
                        task: ray_client_pb2.ClientTask,

After Change

        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,
                        task: ray_client_pb2.ClientTask,

Instances