diff --git a/notifications_consumer/processors/email_feed/processor.py b/notifications_consumer/processors/email_feed/processor.py index 1aaaa1eeba8fca3b517b384cb06dfea93b4054ab..58422867c8f278d5d4ad57185693f4d4d00b0353 100644 --- a/notifications_consumer/processors/email_feed/processor.py +++ b/notifications_consumer/processors/email_feed/processor.py @@ -4,7 +4,6 @@ import logging from datetime import datetime from typing import Dict -from notifications_consumer.auditing import audit_notification, get_audit_notification from notifications_consumer.config import ENV_DEV, Config from notifications_consumer.email_whitelist import get_email_whitelist from notifications_consumer.processors.email.utils import create_email, send_emails @@ -47,7 +46,7 @@ class EmailFeedProcessor(Processor): recipient_email, Config.EMAIL_WHITELIST_GROUP_ID, ) - audit_notification(kwargs["notification_id"], {"event": "Skipped, not in whitelist"}, recipient_email) + # audit_notification(kwargs["notification_id"], {"event": "Skipped, not in whitelist"}, recipient_email) return title = f'{Config.FEED_TITLE} Summary - {datetime.now().strftime("%d %B %Y")}' @@ -76,14 +75,14 @@ class EmailFeedProcessor(Processor): context, ) - if get_audit_notification(kwargs["notification_id"], recipient_email): - logging.warning( - "%s is already sent to %s according ot etcd, skipping", kwargs["notification_id"], recipient_email - ) - return + # if get_audit_notification(kwargs["notification_id"], recipient_email): + # logging.warning( + # "%s is already sent to %s according ot etcd, skipping", kwargs["notification_id"], recipient_email + # ) + # return ret = send_emails([email]) - audit_notification(kwargs["notification_id"], {"event": "Sent"}, recipient_email) + # audit_notification(kwargs["notification_id"], {"event": "Sent"}, recipient_email) return ret def read_message(self, message: Dict):