make style

Author: xinge-ji

sqlmesh/core/engine_adapter/doris.py

@@ -17,7 +17,6 @@
     PandasNativeFetchDFSupportMixin,
 )
 from sqlmesh.core.engine_adapter.shared import (
-    CatalogSupport,
     CommentCreationTable,
     CommentCreationView,
     DataObject,
@@ -55,10 +54,8 @@ class DorisEngineAdapter(
     SUPPORTS_MATERIALIZED_VIEW_SCHEMA = True
     SUPPORTS_CREATE_DROP_CATALOG = False
     INSERT_OVERWRITE_STRATEGY = InsertOverwriteStrategy.DELETE_INSERT
-
-    @property
-    def catalog_support(self) -> CatalogSupport:
-        return CatalogSupport.FULL_SUPPORT
+    # default setting `enable_unicode_name_support=false` so it is incompatible with unicode characters in model names
+    QUOTE_IDENTIFIERS_IN_VIEWS = False
 
     def create_schema(
         self,
@@ -1120,4 +1117,4 @@ def _properties_to_expressions(self, properties: t.Dict[str, t.Any]) -> t.List[e
             if not isinstance(value, exp.Expression):
                 value = exp.Literal.string(str(value))
             expressions.append(exp.Property(this=exp.Literal.string(str(key)), value=value))
-        return expressions
+        return expressions

tests/core/engine_adapter/integration/test_integration_doris.py

@@ -30,4 +30,4 @@ def engine_adapter(ctx: TestContext) -> DorisEngineAdapter:
 
 def test_engine_adapter(ctx: TestContext):
     assert isinstance(ctx.engine_adapter, DorisEngineAdapter)
-    assert ctx.engine_adapter.fetchone("select 1") == (1,)
+    assert ctx.engine_adapter.fetchone("select 1") == (1,)

tests/core/engine_adapter/test_doris.py

@@ -7,7 +7,6 @@
 from tests.core.engine_adapter import to_sql_calls
 
 from sqlmesh.core.engine_adapter.doris import DorisEngineAdapter
-from sqlmesh.utils.errors import UnsupportedCatalogOperationError
 
 from pytest_mock.plugin import MockerFixture
 
@@ -133,16 +132,11 @@ def test_create_table_like(make_mocked_engine_adapter: t.Callable[..., DorisEngi
 def test_create_schema(make_mocked_engine_adapter: t.Callable[..., DorisEngineAdapter]):
     adapter = make_mocked_engine_adapter(DorisEngineAdapter)
     adapter.create_schema("test_schema")
-    adapter.create_schema("test_schema", ignore_if_exists=False)
 
     assert to_sql_calls(adapter) == [
         "CREATE DATABASE IF NOT EXISTS `test_schema`",
-        "CREATE DATABASE `test_schema`",
     ]
 
-    with pytest.raises(UnsupportedCatalogOperationError):
-        adapter.create_schema("test_catalog.test_schema")
-
 
 def test_drop_schema(make_mocked_engine_adapter: t.Callable[..., DorisEngineAdapter]):
     adapter = make_mocked_engine_adapter(DorisEngineAdapter)