Don't emit error messages as emails

Fixes #114.
nasa-gcn · Aug 13, 2023 · 375dfd1 · 375dfd1
1 parent 0236e81
commit 375dfd1
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/gcn_email/core.py b/gcn_email/core.py
@@ -92,6 +92,10 @@ def recieve_alerts(consumer):
     table = get_email_notification_subscription_table()
     while True:
         for message in consumer.consume(timeout=1):
+            error = message.error()
+            if error is not None:
+                log.error('Error consuming message: %s', error)
+                continue
             topic = message.topic()
             metrics.received.labels(topic).inc()
             recipients = query_and_project_subscribers(table, topic)