This message was deleted.

Is this the full code? I can’t see what would cause this immediately

not really, what I am trying to do is, since I have a large of models to run and apply, I want to break model training and forecasting into 2 processes and use 2 Pandas UDF to make it happen. But I am not sure how can I log the statsforecast model in ML Flow and how can I call them.

I’ll make an example for you later today

thank you so much!!

Ok so I have an end to end script that is working: https://github.com/kvnkho/demos/blob/main/fugue/fugue-nixtla-mlflow.py I don’t know MLFlow well enough to get the nested runs working yet. I can probably revisit it more Wednesday, but I think this should give a clear picture of where this is going. Happy to hop on a call and discuss. I’m just a bit busy today and tom. Also, I am not with the Nixtla team if ever they correct me lol, am just a friend. I am part of the Fugue team where we work on bringing Python and Pandas code to Spark easily (as you’ll see in the end of the script). If you don’t want to use Fugue, it’s fine, you can still use something like pandas_udf. It will just be some extra code to re-write (especially around Schema). I am presenting in PyData NYC next week and this is a good use case so I’ll be use to understand it more and get it working by then. If you do get the nested client working, I’d love to see it!

Thank you so much for sharing Kevin, I will look into the code and fit the same on my dataset to test. Appreciate you efforts with the script!!

Hey! Responding to general chat so Nixtla team can chime in. So my understanding with

statsforecast

is you can either use

.forecast()

which is a straight forecasing or

.fit()

and

.predict()

. If you want to decouple training and prediction time, just call the

.fit()

method and then you can save that pickle object to be used later. The pickle should be able to be used with exogenous regressions because it saves the model weights and info. That is how it was done with sklearn before also. I don’t believe

statsforecast

has it built in yet but you can just make your own saving and loading functions pretty easily.

this might be another dumb question...but how can I get the location of the pickel file logged in the experiment? like, when I do pickle.load() what would be the location of model_filename?

I don’t know MLFlow enough but I think you get the MLFlow client, supply experiment name, get the artifact location, make the URL and then load the model

yep I saw the same post and got more confused 😄 will try this load_dict method! thanks a ton!

No not the

load_dict

. The one above

download_artifacts

.