fix(notificator): process queue more often (#2407)

* fix(notificator): process queue more often

RHINENG-28479

* chore(notificator): make log messages shorter, adjust debug levels

Author: jdobes

notificator/notificator.py

@@ -30,7 +30,7 @@
 
 CFG = Config()
 LOGGER = get_logger(__name__)
-NOTIFICATOR_PERIOD = 3 * 60  # 3 minutes
+NOTIFICATOR_PERIOD = 60  # 1 minute
 
 
 class NotificatorConditions:

notificator/notificator_queue.py

@@ -252,11 +252,11 @@ async def _process_normal_queue(self):
                     # account-level: existing dedup logic
                     if not await self._is_already_notified(item.rh_account_id, item.cve_id, notif_event):
                         self._send_kafka_notif(item.org_id, inventory_id, display_name, notif_event.value, cve_events, loop=self.loop)
-                        LOGGER.info("Sending notification about CVE: %s (%s) for %s org", item.cve, item.cve_id, item.org_id)
+                        LOGGER.info("Sent %s, cve=%s, org_id=%s", notif_event.value, item.cve, item.org_id)
                         SENT_NOTIFICATIONS.inc()
                         new_notified.add(notif_event)
                     else:
-                        LOGGER.info("Skipping notification about CVE: %s (%s), already sent for %s org", item.cve, item.cve_id, item.org_id)
+                        LOGGER.debug("Skipped %s (already sent), cve=%s, org_id=%s", notif_event.value, item.cve, item.org_id)
 
             # register sent account-level notifs
             if new_notified:
@@ -267,7 +267,7 @@ async def _process_normal_queue(self):
         # send batched system-level notifications (one message per system per notification type)
         for (inventory_id, org_id, display_name, notif_event), events in system_notif_batch.items():
             self._send_kafka_notif(org_id, inventory_id, display_name, notif_event.value, events, loop=self.loop)
-            LOGGER.info("Sending system notification %s for inventory %s (%s CVEs)", notif_event.value, inventory_id, len(events))
+            LOGGER.info("Sent %s, inventory_id=%s, cve_count=%s", notif_event.value, inventory_id, len(events))
             SENT_NOTIFICATIONS.inc()
 
     async def _process_unknown_queue(self):