Add Sentry support (AlmaLinux#113)

Author: Kwaizer

alts/scheduler/app.py

@@ -6,6 +6,7 @@
 
 import aiohttp
 import logging
+import sentry_sdk
 import signal
 import urllib.parse
 from threading import Event
@@ -40,6 +41,15 @@
 graceful_terminate_event = Event()
 http_bearer_scheme = HTTPBearer()
 
+if CONFIG.sentry_dsn:
+    sentry_sdk.init(
+        dsn=CONFIG.sentry_dsn,
+        traces_sample_rate=CONFIG.sentry_traces_sample_rate,
+        environment=CONFIG.sentry_environment,
+        ignore_errors=[
+            ConnectionResetError
+        ],
+    )
 
 def get_celery_task_result(task_id: str, timeout: int = 1) -> tuple:
     """

alts/shared/models.py

@@ -384,3 +384,6 @@ class SchedulerConfig(CeleryConfig):
     working_directory: str = '/srv/alts/scheduler'
     jwt_secret: str
     hashing_algorithm: str = 'HS256'
+    sentry_dsn: str = None
+    sentry_traces_sample_rate: float = 0.2
+    sentry_environment: str = 'dev'

alts/worker/app.py

@@ -1,5 +1,6 @@
 import itertools
 import logging
+import sentry_sdk
 
 from celery import Celery
 from kombu import Exchange, Queue
@@ -32,6 +33,16 @@
 celery_app.conf.task_default_exchange = 'default'
 celery_app.conf.task_default_routing_key = 'default'
 
+if CONFIG.sentry_dsn:
+    sentry_sdk.init(
+        dsn=CONFIG.sentry_dsn,
+        traces_sample_rate=CONFIG.sentry_traces_sample_rate,
+        environment=CONFIG.sentry_environment,
+        ignore_errors=[
+            ConnectionResetError
+        ],
+    )
+
 if CONFIG.use_ssl:
     if not getattr(CONFIG, 'ssl_config'):
         raise ValueError('Empty SSL configuration section')

requirements/base.txt

@@ -12,5 +12,6 @@ pulpcore-client==3.61.0
 pydantic==2.9.2
 pyone==6.10.0
 requests==2.32.3
+sentry-sdk==2.22.0
 syncer==2.0.3
 tap.py==3.1