Y_rec_df = transform(Y_hat_df.reset_index(), 
                     fugueReoncile, 
                     params={},
                     schema=fugueSchema, 
                     partition={"by": "ds"}, 
                     engine=spark)