fix: test failures — add pytest-asyncio config, skip guards for optional deps, soft-import geopandas

Author: beatfactor

azure_handler/storage.py

@@ -53,11 +53,14 @@ def _resolve(self, path: str) -> Path:
         return full
 
     def save_parquet(self, df: "pd.DataFrame", path: str) -> str:
-        import geopandas as gpd
-
         full = self._resolve(path)
 
-        if "latitude" in df.columns and "longitude" in df.columns:
+        try:
+            import geopandas as gpd
+        except ImportError:
+            gpd = None
+
+        if gpd and "latitude" in df.columns and "longitude" in df.columns:
             valid = df["latitude"].notna() & df["longitude"].notna()
             if valid.any():
                 geometry = gpd.points_from_xy(
@@ -129,14 +132,18 @@ def _ensure_container(self, container: str) -> None:
 
     def save_parquet(self, df: "pd.DataFrame", path: str) -> str:
         import tempfile
-        import geopandas as gpd
+
+        try:
+            import geopandas as gpd
+        except ImportError:
+            gpd = None
 
         container = path.split("/")[0]
         blob_name = "/".join(path.split("/")[1:])
         self._ensure_container(container)
 
         with tempfile.NamedTemporaryFile(suffix=".parquet", delete=True) as tmp:
-            if "latitude" in df.columns and "longitude" in df.columns:
+            if gpd and "latitude" in df.columns and "longitude" in df.columns:
                 valid = df["latitude"].notna() & df["longitude"].notna()
                 if valid.any():
                     geometry = gpd.points_from_xy(

pytest.ini

@@ -0,0 +1,2 @@
+[pytest]
+asyncio_mode = auto

test/test_adcp_parser.py

@@ -60,12 +60,14 @@ def test_dimensions(self, adcp_raw_file):
         assert ds.sizes["range"] == 70
         assert ds.sizes["beam"] == 4
 
+    @pytest.mark.skipif(not HAS_DOLFYN, reason="dolfyn not installed")
     def test_file_not_found(self):
         from ingest.adcp_parser import read_rdi
 
         with pytest.raises((FileNotFoundError, RuntimeError)):
             read_rdi(Path("/nonexistent/file.raw"))
 
+    @pytest.mark.skipif(not HAS_DOLFYN, reason="dolfyn not installed")
     def test_wrong_extension(self, tmp_path):
         from ingest.adcp_parser import read_rdi
 

test/test_pipeline.py

@@ -10,6 +10,7 @@
 
 from azure_handler.storage import LocalStorage
 from config import EdgeConfig
+from ingest.adapter import HAS_NMEA
 from process.pipeline import process_file
 
 
@@ -65,6 +66,7 @@ async def test_process_empty_csv(config, storage, tmp_path):
 # NMEA file processing
 # ------------------------------------------------------------------
 
+@pytest.mark.skipif(not HAS_NMEA, reason="oceanstream NMEA parser not installed")
 @pytest.mark.asyncio
 async def test_process_nmea_file(config, storage, tmp_path):
     """Process a small NMEA .txt file."""

test/test_stream_parser.py

@@ -5,6 +5,7 @@
 import pytest
 import pandas as pd
 
+from ingest.adapter import HAS_NMEA
 from ingest.stream_parser import (
     detect_format,
     parse_csv_line,
@@ -39,6 +40,7 @@ def test_gn_prefix(self):
 # parse_nmea_line
 # ------------------------------------------------------------------
 
+@pytest.mark.skipif(not HAS_NMEA, reason="oceanstream NMEA parser not installed")
 class TestParseNmeaLine:
     def test_gga_with_timestamp(self):
         line = "2024-02-17T00:00:01.346168Z $GPGGA,000000.00,3242.3916,N,11714.1640,W,1,10,0.8,10.2,M,-34.3,M,,*66"