feat: Add severity tags to all AppSignal error reports

Use send_error_with_context() with set_params() to tag errors
with severity (critical/error/warning) and source location across
both app.py and ai_indexer.py.

ai_indexer.py

@@ -17,7 +17,7 @@ from pathlib import Path
 from typing import List, Dict, Optional
 import logging
 from opentelemetry import trace
-from appsignal import send_error
+from appsignal import send_error_with_context, set_params
 
 logging.basicConfig(level=logging.INFO)
 logger = logging.getLogger(__name__)
@@ -64,7 +64,8 @@ class LocalMediaIndexer:
             self.processor = AutoProcessor.from_pretrained(model_name)
             logger.info("[OK] Model loaded successfully")
         except Exception as e:
-            send_error(e)
+            with send_error_with_context(e):
+                set_params({"severity": "critical", "source": "model_loading"})
             logger.error(f"[ERROR] Error loading model: {e}")
             raise
 
@@ -109,7 +110,8 @@ class LocalMediaIndexer:
             return frames
 
         except Exception as e:
-            send_error(e)
+            with send_error_with_context(e):
+                set_params({"severity": "warning", "source": "video_frame_extraction", "video_path": video_path})
             logger.error(f"[ERROR] Error extracting frames from {video_path}: {e}")
             return []
 
@@ -135,7 +137,8 @@ class LocalMediaIndexer:
                 image_features = image_features / image_features.norm(dim=-1, keepdim=True)
                 return image_features.cpu().numpy().flatten()
             except Exception as e:
-                send_error(e)
+                with send_error_with_context(e):
+                    set_params({"severity": "error", "source": "image_embedding"})
                 logger.error(f"[ERROR] Error getting embedding: {e}")
                 return None
 
@@ -232,7 +235,8 @@ class LocalMediaIndexer:
                                     logger.info(f"  [OK] Indexed video: {file}")
 
                     except Exception as e:
-                        send_error(e)
+                        with send_error_with_context(e):
+                            set_params({"severity": "warning", "source": "file_indexing", "file": file})
                         logger.error(f"[ERROR] Error processing {file}: {e}")
 
             if not embeddings:
@@ -313,7 +317,8 @@ class LocalMediaIndexer:
                 return results
 
             except Exception as e:
-                send_error(e)
+                with send_error_with_context(e):
+                    set_params({"severity": "error", "source": "indexer_search"})
                 logger.error(f"[ERROR] Search error: {e}")
                 return []
 
@@ -335,7 +340,8 @@ class LocalMediaIndexer:
             logger.info(f"💾 Index saved to {self.index_dir}")
 
         except Exception as e:
-            send_error(e)
+            with send_error_with_context(e):
+                set_params({"severity": "error", "source": "index_save"})
             logger.error(f"[ERROR] Error saving index: {e}")
 
     def load_index(self) -> bool:
@@ -360,6 +366,7 @@ class LocalMediaIndexer:
             return False
 
         except Exception as e:
-            send_error(e)
+            with send_error_with_context(e):
+                set_params({"severity": "error", "source": "index_load"})
             logger.error(f"[ERROR] Error loading index: {e}")
             return False

app.py

@@ -25,7 +25,7 @@ from huggingface_hub import snapshot_download
 load_dotenv()
 
 # --- AppSignal APM ---
-from appsignal import Appsignal, set_category, send_error, set_gauge, increment_counter
+from appsignal import Appsignal, set_category, send_error, send_error_with_context, set_params, set_gauge, increment_counter
 import time
 from opentelemetry.instrumentation.starlette import StarletteInstrumentor
 from opentelemetry import trace
@@ -78,7 +78,8 @@ if IS_HUGGINGFACE_SPACE or not os.path.exists(MEDIA_DIR) or not os.listdir(MEDIA
         )
         logger.info("Media files downloaded successfully")
     except Exception as e:
-        send_error(e)
+        with send_error_with_context(e):
+            set_params({"severity": "warning", "source": "media_download"})
         logger.error(f"Failed to download media files: {e}")
         logger.warning("Continuing without demo media files")
 
@@ -95,7 +96,8 @@ try:
     indexer.index_local_directory(force_reindex=False)
 
 except Exception as e:
-    send_error(e)
+    with send_error_with_context(e):
+        set_params({"severity": "critical", "source": "indexer_init"})
     logger.error(f"❌ Failed to initialize indexer: {e}")
     raise
 
@@ -125,7 +127,8 @@ def semantic_search(query: str, media_type: str = "all", top_k: int = 5) -> str:
         t_start = time.time()
         try:
             if not query or not query.strip():
-                send_error(ValueError("Query cannot be empty"))
+                with send_error_with_context(ValueError("Query cannot be empty")):
+                    set_params({"severity": "warning", "source": "semantic_search"})
                 increment_counter("semantic_search.errors", 1)
                 return json.dumps({"error": "Query cannot be empty"}, indent=2)
 
@@ -164,7 +167,8 @@ def semantic_search(query: str, media_type: str = "all", top_k: int = 5) -> str:
 
         except Exception as e:
             increment_counter("semantic_search.errors", 1)
-            send_error(e)
+            with send_error_with_context(e):
+                set_params({"severity": "error", "source": "semantic_search"})
             logger.error(f"[ERROR] Search error: {e}")
             return json.dumps({"error": str(e)}, indent=2)
 
@@ -183,7 +187,8 @@ def get_media_details(file_path: str) -> str:
         span.set_attribute("media.file_path", file_path or "")
         try:
             if not os.path.exists(file_path):
-                send_error(FileNotFoundError(f"File not found: {file_path}"))
+                with send_error_with_context(FileNotFoundError(f"File not found: {file_path}")):
+                    set_params({"severity": "warning", "source": "get_media_details", "file_path": file_path})
                 return json.dumps({"error": f"File not found: {file_path}"}, indent=2)
 
             stat = os.stat(file_path)
@@ -208,7 +213,8 @@ def get_media_details(file_path: str) -> str:
             return json.dumps(details, indent=2)
 
         except Exception as e:
-            send_error(e)
+            with send_error_with_context(e):
+                set_params({"severity": "error", "source": "get_media_details"})
             logger.error(f"[ERROR] Error getting details: {e}")
             return json.dumps({"error": str(e)}, indent=2)
 
@@ -248,7 +254,8 @@ def reindex_media(force: bool = False) -> str:
 
         except Exception as e:
             increment_counter("reindex.errors", 1)
-            send_error(e)
+            with send_error_with_context(e):
+                set_params({"severity": "error", "source": "reindex_media"})
             logger.error(f"[ERROR] Reindex error: {e}")
             return json.dumps({"error": str(e)}, indent=2)
 
@@ -293,7 +300,8 @@ def get_index_stats() -> str:
             return json.dumps(stats, indent=2)
 
         except Exception as e:
-            send_error(e)
+            with send_error_with_context(e):
+                set_params({"severity": "error", "source": "get_index_stats"})
             logger.error(f"[ERROR] Error getting stats: {e}")
             return json.dumps({"error": str(e)}, indent=2)