events: cleanup code, pep8, better logging.

rhodecode/apps/admin/subscribers.py

@@ -32,6 +32,7 b' def trigger_user_permission_flush(event)'
     automatic flush of permission caches, so the users affected receive new permissions
     Right Away
     """
+
     affected_user_ids = set(event.user_ids)
     for user_id in affected_user_ids:
         cache_namespace_uid = 'cache_user_auth.{}'.format(user_id)

rhodecode/events/__init__.py

@@ -34,7 +34,7 b' def trigger(event, registry=None):'
     # passing the registry as an argument to get rid of it.
     registry = registry or get_current_registry()
     registry.notify(event)
-    log.debug('event %s triggered using registry %s', event, registry)
+    log.debug('event %s triggered using registry %s', event.__class__, registry)
 
     # Until we can work around the problem that VCS operations do not have a
     # pyramid context to work with, we send the events to integrations directly

rhodecode/model/integration.py

@@ -33,7 +33,7 b' from rhodecode import events'
 from rhodecode.integrations.types.base import EEIntegration
 from rhodecode.lib.caching_query import FromCache
 from rhodecode.model import BaseModel
-from rhodecode.model.db import Integration, Repository, RepoGroup
+from rhodecode.model.db import Integration, Repository, RepoGroup, true, false
 from rhodecode.integrations import integration_type_registry
 
 log = logging.getLogger(__name__)
@@ -132,7 +132,7 b' class IntegrationModel(BaseModel):'
             query = self.sa.query(Integration).filter(
                 and_(Integration.repo_id==None,
                      Integration.repo_group_id==None,
-                     Integration.child_repos_only==True)
+                     Integration.child_repos_only == true())
             )
         elif scope == 'all':
             query = self.sa.query(Integration)
@@ -158,7 +158,7 b' class IntegrationModel(BaseModel):'
         query = self.sa.query(
             Integration
         ).filter(
-            Integration.enabled==True
+            Integration.enabled == true()
         )
 
         global_integrations_filter = and_(
@@ -171,7 +171,7 b' class IntegrationModel(BaseModel):'
             root_repos_integrations_filter = and_(
                 Integration.repo_id==None,
                 Integration.repo_group_id==None,
-                Integration.child_repos_only==True,
+                Integration.child_repos_only == true(),
             )
 
             clauses = [
@@ -188,7 +188,7 b' class IntegrationModel(BaseModel):'
                 clauses.append(
                     and_(
                         Integration.repo_group_id==event.repo.group.group_id,
-                        Integration.child_repos_only==True
+                        Integration.child_repos_only == true()
                     )
                 )
                 # repo group cascade to kids
@@ -198,11 +198,10 b' class IntegrationModel(BaseModel):'
                             [group.group_id for group in
                             event.repo.groups_with_parents]
                         ),
-                        Integration.child_repos_only==False
+                        Integration.child_repos_only == false()
                     )
                 )
 
-
             if not event.repo.group: # root repo
                 clauses.append(root_repos_integrations_filter)
 
@@ -219,4 +218,4 b' class IntegrationModel(BaseModel):'
                     FromCache("sql_cache_short", "get_enabled_global_integrations"))
 
         result = query.all()
-        return result
  No newline at end of file
+        return result