Raise an error unsupported lake data in load granule operations

hydrocron/db/load_data.py

@@ -133,6 +133,9 @@ def granule_handler(event, _):
     if ("LakeSP_Prior" in granule_path) & (table_name != constants.SWOT_PRIOR_LAKE_TABLE_NAME):
         raise TableMisMatch(f"Error: Cannot load Prior Lake data into table: '{table_name}'")
 
+    if ("LakeSP_Obs" in granule_path) | ("LakeSP_Unassigned" in granule_path):
+        raise TableMisMatch(f"Error: Cannot load Observed or Unassigned Lake data into table: '{table_name}'")
+
     logging.info("Value of load_benchmarking_data is: %s", load_benchmarking_data)
 
     obscure_data = "true" in os.getenv("OBSCURE_DATA").lower()

tests/test_hydrocron_database.py

@@ -1,3 +1,5 @@
+import pytest
+
 """
 ==============
 test_create_table.py
@@ -72,3 +74,22 @@ def test_delete_item(hydrocron_dynamo_table):
         partition_key=constants.TEST_REACH_ID_VALUE,
         sort_key=constants.TEST_REACH_TIME_VALUE)
     assert hydrocron_dynamo_table.table.item_count == 686
+
+
+def test_track_table_mismatch():
+    """
+    Test track ingest table name mismatch with granule UR.
+    """
+    import hydrocron.db.load_data
+
+    event = {
+        "body": {
+            "granule_path": "s3://podaac-swot-sit-cumulus-protected/SWOT_L2_HR_LakeSP_2.0/SWOT_L2_HR_LakeSP_Obs_020_150_EU_20240825T234434_20240825T235245_PIC0_01.zip",
+            "table_name": "hydrocron-swot-prior-lake-table",
+            "load_benchmarking_data": "False",
+            "track_table": "hydrocron-swot-prior-lake-track-ingest-table"
+        }
+    }
+    with pytest.raises(hydrocron.db.load_data.TableMisMatch) as e:
+        hydrocron.db.load_data.granule_handler(event, None)
+        assert str(e.value) == "Error: Cannot load Observed or Unassigned Lake data into table: 'hydrocron-swot-prior-lake-table'"