fix: use adapter dispatch for reserved keyword aliases instead of double-quotes

Double-quoted identifiers break Spark SQL. Use adapter dispatch with
fabric__ variants that quote 'schema' and 'database' using T-SQL square
brackets, while the default keeps the original unquoted aliases.

Co-Authored-By: Itamar Hartstein <haritamar@gmail.com>

Author: devin-ai-integration[bot]

elementary/monitor/dbt_project/macros/base_queries/resources.sql

@@ -1,4 +1,33 @@
 {% macro get_model_resources(exclude_elementary=true) %}
+    {{ return(adapter.dispatch('get_model_resources', 'elementary_cli')(exclude_elementary)) }}
+{% endmacro %}
+
+
+{% macro default__get_model_resources(exclude_elementary=true) %}
+    {% set model_resources_query %}
+        with dbt_models as (
+            select * from {{ ref('elementary', 'dbt_models') }}
+        )
+
+        select
+            unique_id,
+            name,
+            schema_name as schema,
+            tags,
+            owner as owners,
+            database_name as database
+        from dbt_models
+        {% if exclude_elementary %}
+            where package_name != 'elementary'
+        {% endif %}
+    {% endset %}
+    {% set models_agate = run_query(model_resources_query) %}
+    {% do return(elementary.agate_to_dicts(models_agate)) %}
+{% endmacro %}
+
+
+{% macro fabric__get_model_resources(exclude_elementary=true) %}
+    {# T-SQL: 'schema' and 'database' are reserved keywords — quote with square brackets #}
     {% set model_resources_query %}
         with dbt_models as (
             select * from {{ ref('elementary', 'dbt_models') }}
@@ -7,10 +36,10 @@
         select
             unique_id,
             name,
-            schema_name as "schema",
+            schema_name as [schema],
             tags,
             owner as owners,
-            database_name as "database"
+            database_name as [database]
         from dbt_models
         {% if exclude_elementary %}
             where package_name != 'elementary'
@@ -22,6 +51,36 @@
 
 
 {% macro get_source_resources(exclude_elementary=true) %}
+    {{ return(adapter.dispatch('get_source_resources', 'elementary_cli')(exclude_elementary)) }}
+{% endmacro %}
+
+
+{% macro default__get_source_resources(exclude_elementary=true) %}
+    {% set source_resources_query %}
+        with dbt_sources as (
+            select * from {{ ref('elementary', 'dbt_sources') }}
+        )
+
+        select
+            unique_id,
+            name,
+            source_name,
+            schema_name AS schema,
+            tags,
+            owner AS owners,
+            database_name as database
+        from dbt_sources
+        {% if exclude_elementary %}
+            where package_name != 'elementary'
+        {% endif %}
+    {% endset %}
+    {% set sources_agate = run_query(source_resources_query) %}
+    {% do return(elementary.agate_to_dicts(sources_agate)) %}
+{% endmacro %}
+
+
+{% macro fabric__get_source_resources(exclude_elementary=true) %}
+    {# T-SQL: 'schema' and 'database' are reserved keywords — quote with square brackets #}
     {% set source_resources_query %}
         with dbt_sources as (
             select * from {{ ref('elementary', 'dbt_sources') }}
@@ -31,10 +90,10 @@
             unique_id,
             name,
             source_name,
-            schema_name AS "schema",
+            schema_name AS [schema],
             tags,
             owner AS owners,
-            database_name as "database"
+            database_name as [database]
         from dbt_sources
         {% if exclude_elementary %}
             where package_name != 'elementary'

elementary/monitor/dbt_project/macros/get_models_runs.sql

@@ -1,4 +1,45 @@
 {%- macro get_models_runs(days_back = 7, exclude_elementary=false) -%}
+    {{ return(adapter.dispatch('get_models_runs', 'elementary_cli')(days_back, exclude_elementary)) }}
+{%- endmacro -%}
+
+
+{%- macro default__get_models_runs(days_back = 7, exclude_elementary=false) -%}
+    {% set models_runs_query %}
+        with model_runs as (
+            select
+                *,
+                row_number() over (partition by unique_id order by generated_at desc) as invocations_rank_index
+            from {{ ref('elementary', 'model_run_results') }}
+        )
+
+        select
+            unique_id,
+            invocation_id,
+            name,
+            schema_name as schema,
+            status,
+            case
+                when status != 'success' then 0
+                else round({{ elementary.edr_cast_as_numeric('execution_time') }}, 1)
+            end as execution_time,
+            full_refresh,
+            materialization,
+            case when invocations_rank_index = 1 then compiled_code else NULL end as compiled_code,
+            generated_at
+        from model_runs
+        where {{ elementary.edr_datediff(elementary.edr_cast_as_timestamp('generated_at'), elementary.edr_current_timestamp(), 'day') }} < {{ days_back }}
+        {% if exclude_elementary %}
+          and unique_id not like 'model.elementary.%'
+        {% endif %}
+        order by generated_at
+    {% endset %}
+    {% set models_runs_agate = run_query(models_runs_query) %}
+    {% do return(elementary.agate_to_dicts(models_runs_agate)) %}
+{%- endmacro -%}
+
+
+{%- macro fabric__get_models_runs(days_back = 7, exclude_elementary=false) -%}
+    {# T-SQL: 'schema' and 'database' are reserved keywords — quote with square brackets #}
     {% set models_runs_query %}
         with model_runs as (
             select
@@ -11,7 +52,7 @@
             unique_id,
             invocation_id,
             name,
-            schema_name as "schema",
+            schema_name as [schema],
             status,
             case
                 when status != 'success' then 0