debugging

NTIA · Apr 11, 2024 · c8550a8 · c8550a8
1 parent 1052fc2
commit c8550a8
Showing 1 changed file with 6 additions and 3 deletions.
diff --git 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")