fix lint

ClickHouse · Aug 21, 2024 · 936b24e · 936b24e
1 parent ec35fb3
commit 936b24e
Showing 1 changed file with 16 additions and 4 deletions.
diff --git a/tests/integration/adapter/incremental/test_schema_change.py b/tests/integration/adapter/incremental/test_schema_change.py
@@ -45,7 +45,10 @@ def models(self):
 
     @pytest.mark.parametrize("model", ("schema_change_ignore", "schema_change_distributed_ignore"))
     def test_ignore(self, project, model):
-        if model == "schema_change_distributed_ignore" and os.environ.get('DBT_CH_TEST_CLUSTER', '').strip() == '':
+        if (
+            model == "schema_change_distributed_ignore"
+            and os.environ.get('DBT_CH_TEST_CLUSTER', '').strip() == ''
+        ):
             pytest.skip("Not on a cluster")
         run_dbt(["run", "--select", model])
         result = project.run_sql(f"select * from {model} order by col_1", fetch="all")
@@ -57,7 +60,10 @@ def test_ignore(self, project, model):
 
     @pytest.mark.parametrize("model", ("schema_change_fail", "schema_change_distributed_fail"))
     def test_fail(self, project, model):
-        if model == "schema_change_distributed_fail" and os.environ.get('DBT_CH_TEST_CLUSTER', '').strip() == '':
+        if (
+            model == "schema_change_distributed_fail"
+            and os.environ.get('DBT_CH_TEST_CLUSTER', '').strip() == ''
+        ):
             pytest.skip("Not on a cluster")
         run_dbt(["run", "--select", model])
         result = project.run_sql(f"select * from {model} order by col_1", fetch="all")
@@ -75,7 +81,10 @@ def test_fail(self, project, model):
 
     @pytest.mark.parametrize("model", ("schema_change_append", "schema_change_distributed_append"))
     def test_append(self, project, model):
-        if model == "schema_change_distributed_append" and os.environ.get('DBT_CH_TEST_CLUSTER', '').strip() == '':
+        if (
+                model == "schema_change_distributed_append"
+                and os.environ.get('DBT_CH_TEST_CLUSTER', '').strip() == ''
+        ):
             pytest.skip("Not on a cluster")
         run_dbt(["run", "--select", model])
         result = project.run_sql(f"select * from {model} order by col_1", fetch="all")
@@ -158,7 +167,10 @@ def test_fail(self, project, model):
         "model", ("complex_schema_change_sync", "complex_schema_change_distributed_sync")
     )
     def test_sync(self, project, model):
-        if model == "complex_schema_change_distributed_sync" and os.environ.get('DBT_CH_TEST_CLUSTER', '').strip() == '':
+        if (
+                model == "complex_schema_change_distributed_sync"
+                and os.environ.get('DBT_CH_TEST_CLUSTER', '').strip() == ''
+        ):
             pytest.skip("Not on a cluster")
         run_dbt(["run", "--select", model])
         result = project.run_sql(f"select * from {model} order by col_1", fetch="all")