Use black code formatter

Author: mikicz

.pre-commit-config.yaml

@@ -0,0 +1,6 @@
+repos:
+-   repo: https://github.com/ambv/black
+    rev: 19.10b0
+    hooks:
+    - id: black
+      language_version: python3.7

django_pgviews/__init__.py

@@ -1 +1 @@
-default_app_config = 'django_pgviews.apps.ViewConfig'
+default_app_config = "django_pgviews.apps.ViewConfig"

django_pgviews/apps.py

@@ -3,30 +3,32 @@
 from django import apps
 from django.db.models import signals
 
-log = logging.getLogger('django_pgviews.sync_pgviews')
+log = logging.getLogger("django_pgviews.sync_pgviews")
 
 
 class ViewConfig(apps.AppConfig):
     """The base configuration for Django PGViews. We use this to setup our
     post_migrate signal handlers.
     """
+
     counter = 0
-    name = 'django_pgviews'
-    verbose_name = 'Django Postgres Views'
+    name = "django_pgviews"
+    verbose_name = "Django Postgres Views"
 
     def sync_pgviews(self, sender, app_config, **kwargs):
         """Forcibly sync the views.
         """
         self.counter = self.counter + 1
         total = len([a for a in apps.apps.get_app_configs() if a.models_module is not None])
-        
+
         if self.counter == total:
-            log.info('All applications have migrated, time to sync')
+            log.info("All applications have migrated, time to sync")
             # Import here otherwise Django doesn't start properly
             # (models in app init are not allowed)
             from .models import ViewSyncer
+
             vs = ViewSyncer()
-            vs.run(force=True, update=True) 
+            vs.run(force=True, update=True)
 
     def ready(self):
         """Find and setup the apps to set the post_migrate hooks for.

django_pgviews/db/__init__.py

@@ -12,7 +12,6 @@ def get_fields_by_name(model_cls, *field_names):
          ...,
          'date_joined': <django.db.models.fields.DateTimeField: date_joined>}
     """
-    if '*' in field_names:
+    if "*" in field_names:
         return dict((field.name, field) for field in model_cls._meta.fields)
-    return dict((field_name, model_cls._meta.get_field(field_name))
-                for field_name in field_names)
+    return dict((field_name, model_cls._meta.get_field(field_name)) for field_name in field_names)

django_pgviews/db/sql/compiler.py

@@ -5,6 +5,7 @@ class NonQuotingCompiler(compiler.SQLCompiler):
     """Compiler for functions/statements that doesn't quote the db_table
     attribute.
     """
+
     def quote_name_unless_alias(self, name):
         """Don't quote the name.
         """
@@ -17,5 +18,5 @@ def quote_name_unless_alias(self, name):
     def as_sql(self, *args, **kwargs):
         """Messy hack to create some table aliases for us.
         """
-        self.query.table_map[self.query.model._meta.db_table] = ['']
+        self.query.table_map[self.query.model._meta.db_table] = [""]
         return super(NonQuotingCompiler, self).as_sql(*args, **kwargs)

django_pgviews/db/sql/query.py

@@ -7,11 +7,12 @@
 class NonQuotingQuery(query.Query):
     """Query class that uses the NonQuotingCompiler.
     """
+
     def get_compiler(self, using=None, connection=None):
         """Get the NonQuotingCompiler object.
         """
         if using is None and connection is None:
-            raise ValueError('Need either using or connection')
+            raise ValueError("Need either using or connection")
         if using:
             connection = connections[using]
 

django_pgviews/management/commands/clear_pgviews.py

@@ -7,7 +7,7 @@
 from django_pgviews.view import clear_view, View, MaterializedView
 
 
-log = logging.getLogger('django_pgviews.sync_pgviews')
+log = logging.getLogger("django_pgviews.sync_pgviews")
 
 
 class Command(BaseCommand):
@@ -17,19 +17,17 @@ def handle(self, **options):
         """
         """
         for view_cls in apps.get_models():
-            if not (isinstance(view_cls, type) and
-                    issubclass(view_cls, View) and
-                    hasattr(view_cls, 'sql')):
+            if not (isinstance(view_cls, type) and issubclass(view_cls, View) and hasattr(view_cls, "sql")):
                 continue
-            python_name = '{}.{}'.format(view_cls._meta.app_label, view_cls.__name__)
+            python_name = "{}.{}".format(view_cls._meta.app_label, view_cls.__name__)
             status = clear_view(
-                connection, view_cls._meta.db_table,
-                materialized=isinstance(view_cls(), MaterializedView))
-            if status == 'DROPPED':
-                msg = 'dropped'
+                connection, view_cls._meta.db_table, materialized=isinstance(view_cls(), MaterializedView)
+            )
+            if status == "DROPPED":
+                msg = "dropped"
             else:
-                msg = 'not dropped'
-            log.info("%(python_name)s (%(view_name)s): %(msg)s" % {
-                'python_name': python_name,
-                'view_name': view_cls._meta.db_table,
-                'msg': msg})
+                msg = "not dropped"
+            log.info(
+                "%(python_name)s (%(view_name)s): %(msg)s"
+                % {"python_name": python_name, "view_name": view_cls._meta.db_table, "msg": msg}
+            )

django_pgviews/management/commands/sync_pgviews.py

@@ -8,24 +8,28 @@
 from django_pgviews.models import ViewSyncer
 
 
-log = logging.getLogger('django_pgviews.sync_pgviews')
+log = logging.getLogger("django_pgviews.sync_pgviews")
 
 
 class Command(BaseCommand):
     help = """Create/update Postgres views for all installed apps."""
-    
+
     def add_arguments(self, parser):
-        parser.add_argument('--no-update',
-            action='store_false',
-            dest='update',
+        parser.add_argument(
+            "--no-update",
+            action="store_false",
+            dest="update",
             default=True,
-            help="""Don't update existing views, only create new ones.""")
-        parser.add_argument('--force',
-            action='store_true',
-            dest='force',
+            help="""Don't update existing views, only create new ones.""",
+        )
+        parser.add_argument(
+            "--force",
+            action="store_true",
+            dest="force",
             default=False,
             help="""Force replacement of pre-existing views where
-            breaking changes have been made to the schema.""")
+            breaking changes have been made to the schema.""",
+        )
 
     def handle(self, force, update, **options):
         vs = ViewSyncer()

django_pgviews/models.py

@@ -6,17 +6,15 @@
 from django_pgviews.view import create_view, View, MaterializedView
 from django_pgviews.signals import view_synced, all_views_synced
 
-log = logging.getLogger('django_pgviews.sync_pgviews')
+log = logging.getLogger("django_pgviews.sync_pgviews")
 
 
 class ViewSyncer(object):
     def run(self, force, update, **options):
         self.synced = []
         backlog = []
         for view_cls in apps.get_models():
-            if not (isinstance(view_cls, type) and
-                    issubclass(view_cls, View) and
-                    hasattr(view_cls, 'sql')):
+            if not (isinstance(view_cls, type) and issubclass(view_cls, View) and hasattr(view_cls, "sql")):
                 continue
             backlog.append(view_cls)
         loop = 0
@@ -25,57 +23,62 @@ def run(self, force, update, **options):
             backlog = self.run_backlog(backlog, force, update)
 
         if loop >= 10:
-            log.warn('pgviews dependencies hit limit. Check if your model dependencies are correct')
+            log.warn("pgviews dependencies hit limit. Check if your model dependencies are correct")
         else:
             all_views_synced.send(sender=None)
 
     def run_backlog(self, models, force, update):
-        '''Installs the list of models given from the previous backlog
+        """Installs the list of models given from the previous backlog
 
         If the correct dependent views have not been installed, the view
         will be added to the backlog.
 
         Eventually we get to a point where all dependencies are sorted.
-        '''
+        """
         backlog = []
         for view_cls in models:
             skip = False
-            name = '{}.{}'.format(view_cls._meta.app_label, view_cls.__name__)
+            name = "{}.{}".format(view_cls._meta.app_label, view_cls.__name__)
             for dep in view_cls._dependencies:
                 if dep not in self.synced:
                     skip = True
             if skip is True:
                 backlog.append(view_cls)
-                log.info('Putting pgview at back of queue: %s', name)
-                continue # Skip
+                log.info("Putting pgview at back of queue: %s", name)
+                continue  # Skip
 
             try:
-                status = create_view(connection, view_cls._meta.db_table,
-                        view_cls.sql, update=update, force=force,
-                        materialized=isinstance(view_cls(), MaterializedView),
-                        index=view_cls._concurrent_index)
+                status = create_view(
+                    connection,
+                    view_cls._meta.db_table,
+                    view_cls.sql,
+                    update=update,
+                    force=force,
+                    materialized=isinstance(view_cls(), MaterializedView),
+                    index=view_cls._concurrent_index,
+                )
                 view_synced.send(
-                    sender=view_cls, update=update, force=force, status=status,
-                    has_changed=status not in ('EXISTS', 'FORCE_REQUIRED'))
+                    sender=view_cls,
+                    update=update,
+                    force=force,
+                    status=status,
+                    has_changed=status not in ("EXISTS", "FORCE_REQUIRED"),
+                )
                 self.synced.append(name)
             except Exception as exc:
                 exc.view_cls = view_cls
                 exc.python_name = name
                 raise
             else:
-                if status == 'CREATED':
+                if status == "CREATED":
                     msg = "created"
-                elif status == 'UPDATED':
+                elif status == "UPDATED":
                     msg = "updated"
-                elif status == 'EXISTS':
+                elif status == "EXISTS":
                     msg = "already exists, skipping"
-                elif status == 'FORCED':
+                elif status == "FORCED":
                     msg = "forced overwrite of existing schema"
-                elif status == 'FORCE_REQUIRED':
-                    msg = (
-                        "exists with incompatible schema, "
-                        "--force required to update")
-                log.info("pgview %(python_name)s %(msg)s" % {
-                    'python_name': name,
-                    'msg': msg})
+                elif status == "FORCE_REQUIRED":
+                    msg = "exists with incompatible schema, " "--force required to update"
+                log.info("pgview %(python_name)s %(msg)s" % {"python_name": name, "msg": msg})
         return backlog

django_pgviews/signals.py

@@ -1,6 +1,5 @@
 from django.dispatch import Signal
 
 
-view_synced = Signal(
-    providing_args=['update', 'force', 'status', 'has_changed'])
+view_synced = Signal(providing_args=["update", "force", "status", "has_changed"])
 all_views_synced = Signal()