Enable Sentry in the RMQ Worker

alephdata · Jun 5, 2024 · 1ed6307 · 1ed6307
1 parent 397acbb
commit 1ed6307
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/servicelayer/taskqueue.py b/servicelayer/taskqueue.py
@@ -391,6 +391,16 @@ def __init__(
         self.version = version
         self.local_queue = Queue()
         self.prefetch_count_mapping = prefetch_count_mapping
+        if settings.SENTRY_DSN:
+            import sentry_sdk
+
+            sentry_sdk.init(
+                dsn=settings.SENTRY_DSN,
+                traces_sample_rate=0,
+                release=settings.SENTRY_RELEASE,
+                environment=settings.SENTRY_ENVIRONMENT,
+                send_default_pii=False,
+            )
 
     def on_signal(self, signal, _):
         log.warning(f"Shutting down worker (signal {signal})")