lint

Author: rcampos87

clickhouse_backend/patch/migrations.py

@@ -71,7 +71,6 @@ def Migration(self):
                 # has distributed migrations enabled and a migration cluster is set.
                 # otherwise, create a regular merge tree.
                 if _should_distribute_migrations(self.connection):
-
                     has_replicas = _check_replicas(self.connection)
 
                     Engine = models.MergeTree
@@ -130,7 +129,9 @@ class Meta:
                             app_label = "migrations"
                             db_table = _get_model_table_name(self.connection)
                             engine = models.MergeTree(order_by=("app", "name"))
-                            cluster = getattr(self.connection, "migration_cluster", None)
+                            cluster = getattr(
+                                self.connection, "migration_cluster", None
+                            )
 
                         def __str__(self):
                             return "Migration %s for %s" % (self.name, self.app)

tests/migrations/test_loader.py

@@ -94,12 +94,22 @@ def assertMigrationTablesExists(self):
         for db in self.databases:
             conn = connections[db]
             tables = conn.introspection.table_names()
-            self.assertIn("django_migrations", tables, f"django_migrations table not found in {conn.alias}")
-            self.assertIn("distributed_django_migrations", tables, f"distributed_django_migrations table not found in {conn.alias}")
+            self.assertIn(
+                "django_migrations",
+                tables,
+                f"django_migrations table not found in {conn.alias}",
+            )
+            self.assertIn(
+                "distributed_django_migrations",
+                tables,
+                f"distributed_django_migrations table not found in {conn.alias}",
+            )
 
     def assertMigrationExists(self, conn, name, app, deleted=False):
         with conn.cursor() as cursor:
-            cursor.execute(f"SELECT * FROM distributed_django_migrations where name = '{name}'")
+            cursor.execute(
+                f"SELECT * FROM distributed_django_migrations where name = '{name}'"
+            )
             res = cursor.fetchall()
 
             self.assertEqual(len(res), 1, f"Migration {name} not found in {conn.alias}")