af5aeb26d96291562884f17cbfbbd917636bc7b7,mindsdb/interfaces/model/model_interface.py,ModelInterface,create,#ModelInterface#Any#,12

Before Change

        self.controller = ModelController.remote()

    def create(self, name):
        fut = self.controller.create.remote(name)
        return ray.get(fut)

    def learn(self, name, from_data, to_predict, datasource_id, kwargs={}):
        join_learn_process = kwargs.get("join_learn_process", False)
        if "join_learn_process" in kwargs:

After Change

        raise Exception("Unable to connect to RPC server")

    def create(self, name):
        return self.proxy.create(name)

    def learn(self, name, from_data, to_predict, datasource_id, kwargs={}):
        return self.proxy.learn(name, from_data, to_predict, datasource_id, kwargs)

Instances