stryle: checkstyle

dbt/adapters/maxcompute/__version__.py

@@ -1 +1 @@
-version = "1.8.0-alpha.13"
+version = "1.8.0-alpha.13"

dbt/adapters/maxcompute/impl.py

@@ -525,8 +525,9 @@ def parse_partition_by(self, raw_partition_by: Any) -> Optional[PartitionConfig]
 
     @available
     @classmethod
-    def mc_render_raw_columns_constraints(cls, raw_columns: Dict[str, Dict[str, Any]],
-                                          partition_config: Optional[PartitionConfig]) -> List:
+    def mc_render_raw_columns_constraints(
+        cls, raw_columns: Dict[str, Dict[str, Any]], partition_config: Optional[PartitionConfig]
+    ) -> List:
         rendered_column_constraints = []
         partition_column = []
         if partition_config and not partition_config.auto_partition():

dbt/adapters/maxcompute/relation.py

@@ -5,7 +5,9 @@
 from dbt.adapters.contracts.relation import RelationType, Path, Policy, RelationConfig
 from odps.models import Table
 
-from dbt.adapters.maxcompute.relation_configs._materialized_view import MaxComputeMaterializedViewConfig
+from dbt.adapters.maxcompute.relation_configs._materialized_view import (
+    MaxComputeMaterializedViewConfig,
+)
 
 Self = TypeVar("Self", bound="MaxComputeRelation")
 
@@ -80,7 +82,7 @@ def from_odps_table(cls, table: Table):
 
     @classmethod
     def materialized_view_from_relation_config(
-            cls, relation_config: RelationConfig
+        cls, relation_config: RelationConfig
     ) -> MaxComputeMaterializedViewConfig:
         return MaxComputeMaterializedViewConfig.from_relation_config(relation_config)
 

dbt/adapters/maxcompute/relation_configs/_materialized_view.py

@@ -52,8 +52,16 @@ def parse_relation_config(cls, relation_config: RelationConfig) -> Dict[str, Any
             "schema": relation_config.schema,
             "project": relation_config.database,
         }
-        items = ["lifecycle", "build_deferred", "columns", "column_comment", "disable_rewrite", "table_comment",
-                 "partition_by", "tblProperties"]
+        items = [
+            "lifecycle",
+            "build_deferred",
+            "columns",
+            "column_comment",
+            "disable_rewrite",
+            "table_comment",
+            "partition_by",
+            "tblProperties",
+        ]
 
         if relation_config:
             for item in items:
@@ -78,7 +86,9 @@ def create_table_sql(self) -> str:
             sql += "("
             for column in self.columns:
                 if self.column_comment and column in self.column_comment:
-                    sql += f"{quote_ref(column)} COMMENT {quote_string(self.column_comment[column])}"
+                    sql += (
+                        f"{quote_ref(column)} COMMENT {quote_string(self.column_comment[column])}"
+                    )
                 else:
                     sql += f"{quote_ref(column)}"
                 sql += ", "
@@ -93,7 +103,7 @@ def create_table_sql(self) -> str:
         if self.tblProperties and len(self.tblProperties) > 0:
             sql += "TBLPROPERTIES( "
             for k, v in self.tblProperties.items():
-                sql += f"\"{k}\"=\"{v}\", "
+                sql += f'"{k}"="{v}", '
             sql = sql[:-2]
             sql += ")\n"
         return sql

dbt/adapters/maxcompute/relation_configs/_partition.py

@@ -23,14 +23,14 @@ def auto_partition(self) -> bool:
     def render(self, with_type: bool = True) -> str:
         default_value = len(self.data_types) == 0
         res = ""
-        for i, field in enumerate(self.fields):
+        for i, field_name in enumerate(self.fields):
             if with_type:
                 if default_value:
-                    column = f"{field} string"
+                    column = f"{field_name} string"
                 else:
-                    column = f"{field} {self.data_types[i]}"
+                    column = f"{field_name} {self.data_types[i]}"
             else:
-                column = field
+                column = field_name
             res += f"{column}, "
         res = res[:-2]  # 去掉最后的逗号和空格
         return res
@@ -42,8 +42,8 @@ def parse(cls, raw_partition_by) -> Optional["PartitionConfig"]:
         try:
             new_dict = {}
             for key, value in raw_partition_by.items():
-                if key in ['fields', 'data_types']:
-                    new_dict[key] = [item.strip() for item in value.split(',')]
+                if key in ["fields", "data_types"]:
+                    new_dict[key] = [item.strip() for item in value.split(",")]
                 else:
                     new_dict[key] = value
             res = cls.from_dict(new_dict)

dbt/adapters/maxcompute/utils.py

@@ -5,12 +5,12 @@
 
 
 def quote_string(value: str) -> str:
-    value.replace('\'', "\\'")
+    value.replace("'", "\\'")
     return f"'{value}'"
 
 
 def quote_ref(value: str) -> str:
-    value.replace('`', "``")
+    value.replace("`", "``")
     return f"`{value}`"
 
 

dbt/include/maxcompute/macros/relations/materialized_view/create.sql

@@ -2,4 +2,4 @@
     {%- set materialized_view = adapter.Relation.materialized_view_from_relation_config(config.model) -%}
     {{ materialized_view.create_table_sql() }}
     as ({{ sql }});
-{% endmacro %}
+{% endmacro %}

dbt/include/maxcompute/macros/relations/materialized_view/rename.sql

@@ -2,4 +2,4 @@
     {{ exceptions.raise_compiler_error(
         "maxcompute materialized view not support rename operation."
     ) }}
-{% endmacro %}
+{% endmacro %}

dbt/include/maxcompute/macros/relations/partition.sql

@@ -6,4 +6,4 @@
     {%- else -%}
         partitioned by ({{ partition_config.render() }})
     {%- endif -%}
-{%- endmacro -%}
+{%- endmacro -%}

dbt/include/maxcompute/macros/utils/date_spine.sql

@@ -119,4 +119,4 @@
 
     select * from filtered
 
-{% endmacro %}
+{% endmacro %}

tests/functional/adapter/test_materialized_view.py

@@ -62,7 +62,7 @@ def test_view_replaces_materialized_view(self, project, my_materialized_view):
         pass
 
     def test_materialized_view_only_updates_after_refresh(
-            self, project, my_materialized_view, my_seed
+        self, project, my_materialized_view, my_seed
     ):
         # poll database
         table_start = self.query_row_count(project, my_seed)