From 3a93e73317b628a78e6c98175dc62114706c1a2d Mon Sep 17 00:00:00 2001 From: bertoz_b Date: Thu, 24 Oct 2024 14:08:13 +0200 Subject: [PATCH] Fixed compatibility issue between read_csv_files_with_dask and... --- SP2XR_toolkit.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/SP2XR_toolkit.py b/SP2XR_toolkit.py index 6a27bce..861f312 100644 --- a/SP2XR_toolkit.py +++ b/SP2XR_toolkit.py @@ -2005,7 +2005,7 @@ def process_pbp_parquet(dir_path_pbp, dir_path_hk, list_hist = [] for idx, (name, group) in enumerate(ddf_pbp.groupby('BC mass bin')): - a, _ = process_hist_and_dist(group, 'time_lag', 'cnts_particles_for_tl_dist', 1, timelag_bins_lims, timelag_bin_ctrs, dt_str, calculate_conc=False, flow=ddf_pbp_hk['Sample Flow Controller Read (vccm)'], rho_eff=None, BC_type=None, t=1) + a, _ = process_hist_and_dist(group, 'time_lag_new', 'cnts_particles_for_tl_dist', 1, timelag_bins_lims, timelag_bin_ctrs, dt_str, calculate_conc=False, flow=ddf_pbp_hk['Sample Flow Controller Read (vccm)'], rho_eff=None, BC_type=None, t=1) a.columns = [f'BC_mass_{inc_mass_bin_ctrs[idx]:.2f}_timelag_{i:.1f}' for i in timelag_bin_ctrs] list_hist.append(a)