update pre-commit python, autoformatting, fix missing pvt data

NTIA · Oct 31, 2024 · 617d04f · 617d04f
1 parent ab72370
commit 617d04f
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git 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
@@ -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