remove parentheses of mv table and view

risingwavelabs · May 7, 2024 · bd35b5a · bd35b5a
1 parent 126122f
commit bd35b5a
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 11 deletions.
diff --git a/dbt/include/risingwave/macros/adapters.sql b/dbt/include/risingwave/macros/adapters.sql
@@ -80,9 +80,8 @@
     {% if contract_config.enforced %}
       {{ get_assert_columns_equivalent(sql) }}
     {%- endif %}
-  as (
-    {{ sql }}
-  );
+  as {{ sql }}
+  ;
 {%- endmacro %}
 
 {% macro risingwave__create_table_as(relation, sql) -%}
@@ -91,9 +90,8 @@
     {% if contract_config.enforced %}
       {{ get_assert_columns_equivalent(sql) }}
     {%- endif %}
-  as (
-    {{ sql }}
-  );
+  as {{ sql }}
+  ;
 {%- endmacro %}
 
 {% macro risingwave__create_materialized_view_as(relation, sql) -%}
@@ -102,12 +100,11 @@
     {% if contract_config.enforced %}
       {{ get_assert_columns_equivalent(sql) }}
     {%- endif %}
-  as (
-    {{ sql }}
-  );
+  as {{ sql }}
+  ;
 {%- endmacro %}
 
-{% macro rising_wave__create_sink(relation, sql) -%}
+{% macro risingwave__create_sink(relation, sql) -%}
     {%- set _format_parameters = config.get("format_parameters") -%}
     {%- set data_format = config.get("data_format") -%}
     {%- set data_encode = config.get("data_encode") -%}

diff --git a/dbt/include/risingwave/macros/materializations/sink.sql b/dbt/include/risingwave/macros/materializations/sink.sql
@@ -24,7 +24,7 @@
         {%- set connector = config.get("connector") -%}
         {% call statement("main") -%}
             {% if connector %}
-              {{ rising_wave__create_sink(target_relation, sql) }}
+              {{ risingwave__create_sink(target_relation, sql) }}
             {% else %}
               {{ risingwave__run_sql(sql) }}
             {% endif %}