diff --git a/.pre-commit-config.yaml b/.pre-commit-config.yaml
index 90d2f9e4..0b4ae5b3 100644
--- a/.pre-commit-config.yaml
+++ b/.pre-commit-config.yaml
@@ -1,5 +1,5 @@
 default_language_version:
-  python: python3.8
+  python: python3.10
 repos:
   - repo: https://github.com/pre-commit/pre-commit-hooks
     rev: v4.6.0
diff --git a/scos_actions/actions/acquire_sea_data_product.py b/scos_actions/actions/acquire_sea_data_product.py
index ecb25ce3..15fb5715 100644
--- a/scos_actions/actions/acquire_sea_data_product.py
+++ b/scos_actions/actions/acquire_sea_data_product.py
@@ -550,7 +550,9 @@ def __call__(self, sensor: Sensor, schedule_entry: dict, task_id: int):
                 )
             # Start data product processing but do not block next IQ capture
             tic = perf_counter()
-            data_products_refs.append(iq_processors[i % NUM_ACTORS].run.remote(measurement_result["data"]))
+            data_products_refs.append(
+                iq_processors[i % NUM_ACTORS].run.remote(measurement_result["data"])
+            )
 
             del measurement_result["data"]
             toc = perf_counter()
@@ -599,6 +601,7 @@ def __call__(self, sensor: Sensor, schedule_entry: dict, task_id: int):
             med_mean_ch_pwrs.append(DATA_TYPE(summaries[1]))
             mean_ch_pwrs.append(DATA_TYPE(summaries[2]))
             median_ch_pwrs.append(DATA_TYPE(summaries[3]))
+            channel_data.extend(data)
             del summaries
 
             pfp_data = ray.get(pfp_ref)
@@ -616,7 +619,7 @@ def __call__(self, sensor: Sensor, schedule_entry: dict, task_id: int):
         for ray_actor in iq_processors:
             ray.kill(ray_actor)
         result_toc = perf_counter()
-        del  iq_processors, channel_data
+        del iq_processors, channel_data
         logger.debug(f"Got all processed data in {result_toc-result_tic:.2f} s")
 
         # Build metadata and convert data to compressed bytes