Merge pull request #81 from fedora-infra/ignore-high-pressure-coprs

Ignore some very high pressure COPR repos

fedmsg.d/fmn.py

@@ -14,6 +14,10 @@
         '.buildsys.repo.init',
         '.buildsys.repo.done',
     ],
+    'ignored_copr_owners': [  # Some COPR repos with very high pressure
+        '@rubygems',
+        '@copr'
+    ],
 
     # Some configuration for the rule processors
     "fmn.rules.utils.use_pkgdb2": False,

fmn/consumer/consumer.py

@@ -64,6 +64,8 @@ def __init__(self, *args, **kwargs):
         self.uri = self.hub.config.get('fmn.sqlalchemy.uri', None)
         self.autocreate = self.hub.config.get('fmn.autocreate', False)
         self.junk_suffixes = self.hub.config.get('fmn.junk_suffixes', [])
+        self.ignored_copr_owners = self.hub.config.get('ignored_copr_owners',
+                                                       [])
 
         if not self.uri:
             raise ValueError('fmn.sqlalchemy.uri must be present')
@@ -96,6 +98,12 @@ def work(self, session, raw_msg):
                 log.debug("Dropping %r", topic)
                 return
 
+        # Ignore high-usage COPRs
+        if topic.startswith('org.fedoraproject.prod.copr.') and \
+                msg['msg']['owner'] in self.ignored_copr_owners:
+            log.debug('Dropping COPR %r by %r' % (topic, msg['msg']['owner']))
+            return
+
         start = time.time()
         log.debug("FMNConsumer received %s %s", msg['msg_id'], msg['topic'])