From c8550a8204386f58a97532e745c464159854895d Mon Sep 17 00:00:00 2001 From: Doug Boulware Date: Thu, 11 Apr 2024 12:46:51 -0600 Subject: [PATCH] debugging --- scos_actions/actions/acquire_sea_data_product.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/scos_actions/actions/acquire_sea_data_product.py b/scos_actions/actions/acquire_sea_data_product.py index bb34fa0d..368b96af 100644 --- a/scos_actions/actions/acquire_sea_data_product.py +++ b/scos_actions/actions/acquire_sea_data_product.py @@ -597,7 +597,9 @@ def __call__(self, sensor: Sensor, schedule_entry: dict, task_id: int): if i == 1: # Power-vs-Time results, a tuple of arrays data, summaries = data # Split the tuple + logger.debug(f"data is {type(data)}: {data}") data = ray.get(data) + logger.debug(f"summaries is {type(summaries)}: {summaries}") summaries = ray.get(summaries) max_max_ch_pwrs.append(DATA_TYPE(summaries[0])) med_mean_ch_pwrs.append(DATA_TYPE(summaries[1])) @@ -610,9 +612,10 @@ def __call__(self, sensor: Sensor, schedule_entry: dict, task_id: int): channel_data.append(ray.get(data)) else: # For 2D arrays (PSD, PVT, PFP) - for d in data: - logger.debug(f"Adding {type(d)}: {d}") - channel_data.append(ray.get(d)) + logger.debug(f"Adding {type(d)}: {d}") + d = ray.get(d) + logger.debug(f"Remove obj was {type(d)}: {d}") + channel_data.extend(d) toc = perf_counter() logger.debug(f"Waited {toc-tic} s for channel data")