feat(ingestor): validation exception handler

lib/ingestor-api/runtime/src/main.py

@@ -1,4 +1,6 @@
 from fastapi import Depends, FastAPI, HTTPException
+from fastapi.exceptions import RequestValidationError
+from fastapi.responses import JSONResponse
 
 from . import collection as collection_loader
 from . import config, dependencies, schemas, services
@@ -123,3 +125,9 @@ def who_am_i(username=Depends(dependencies.get_username)):
     Return username for the provided request
     """
     return {"username": username}
+
+
+# exception handling
+@app.exception_handler(RequestValidationError)
+async def validation_exception_handler(request, exc):
+    return JSONResponse(str(exc), status_code=422)

lib/ingestor-api/runtime/src/schemas.py

@@ -52,7 +52,7 @@ def exists(cls, collection):
 
 class StacCollection(Collection):
     id: str
-    item_assets: Dict
+    item_assets: Optional[Dict]
 
 
 class Status(str, enum.Enum):

lib/ingestor-api/runtime/tests/conftest.py

@@ -248,7 +248,7 @@ def client_authenticated(app):
     """
     from src.dependencies import get_username
 
-    app.dependency_overrides[get_username] = lambda: 'test_user'
+    app.dependency_overrides[get_username] = lambda: "test_user"
     return TestClient(app)
 
 

lib/ingestor-api/runtime/tests/test_registration.py

@@ -119,11 +119,8 @@ def test_validates_missing_assets(
         )
         assert response.status_code == 422, "should get validation error"
         for asset_type in self.example_ingestion.item.assets.keys():
-            assert any(
-                [
-                    err["loc"] == ["body", "assets", asset_type, "href"]
-                    for err in response.json()["detail"]
-                ]
+            assert (
+                asset_type in response.json()
             ), "should reference asset type in validation error response"
         assert (
             len(self.db.fetch_many(status="queued")["items"]) == 0