390258fe22f39a2ae916cb95a06387dfa03f47ed,mltsp/celery_tasks.py,,featurize_ts_file,#Any#Any#Any#,37

Before Change

    
    short_fname = util.shorten_fname(ts_file_path)
    with xr.open_dataset(ts_file_path) as data:
        meta_features = data.meta_features.to_series().to_dict()
        all_features = ft.featurize_single_ts(data.time.values,
                                              data.measurement.values,
                                              data.error.values,
                                              features_to_use, meta_features,

After Change

    
    short_fname = util.shorten_fname(ts_file_path)
    ts = time_series.from_netcdf(ts_file_path)
    all_features = ft.featurize_single_ts(ts, features_to_use,
                                          custom_script_path)
    return (short_fname, all_features, ts.target, ts.meta_features)


@celery_app.task(name="celery_tasks.featurize_ts_data")
def featurize_ts_data(ts, features_to_use, custom_script_path=None,

Instances