From be84b572df2e523042885b1375e2c528e6542fc3 Mon Sep 17 00:00:00 2001 From: Doug Boulware Date: Thu, 11 Apr 2024 12:18:24 -0600 Subject: [PATCH] get remote objects. --- scos_actions/actions/acquire_sea_data_product.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/scos_actions/actions/acquire_sea_data_product.py b/scos_actions/actions/acquire_sea_data_product.py index ad6a6e55..d36b2f2e 100644 --- a/scos_actions/actions/acquire_sea_data_product.py +++ b/scos_actions/actions/acquire_sea_data_product.py @@ -597,6 +597,8 @@ 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 + data = ray.get(data) + summaries = ray.get(summaries) max_max_ch_pwrs.append(DATA_TYPE(summaries[0])) med_mean_ch_pwrs.append(DATA_TYPE(summaries[1])) mean_ch_pwrs.append(DATA_TYPE(summaries[2])) @@ -605,10 +607,12 @@ def __call__(self, sensor: Sensor, schedule_entry: dict, task_id: int): if i == 3: # Separate condition is intentional # APD result: append instead of extend, # since the result is a single 1D array - channel_data.append(data) + channel_data.append(ray.get(data)) else: # For 2D arrays (PSD, PVT, PFP) - channel_data.extend(data) + for d in data: + channel_data.append(ray.get(d)) + toc = perf_counter() logger.debug(f"Waited {toc-tic} s for channel data") all_data.extend(NasctnSeaDataProduct.transform_data(channel_data))