Skip to content

Commit 1739662

Browse files
fix: replace LIMIT with TOP for T-SQL compatibility in CLI dbt macros
Co-Authored-By: Itamar Hartstein <haritamar@gmail.com>
1 parent 7b51cd7 commit 1739662

3 files changed

Lines changed: 10 additions & 2 deletions

File tree

elementary/monitor/dbt_project/macros/get_latest_invocation.sql

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,11 @@
77
{% endif %}
88

99
{% set get_pkg_version_query %}
10+
{% if target.type in ('fabric', 'sqlserver') %}
11+
select top 1 * from {{ invocations_relation }} order by generated_at desc
12+
{% else %}
1013
select * from {{ invocations_relation }} order by generated_at desc limit 1
14+
{% endif %}
1115
{% endset %}
1216
{% set result = elementary.run_query(get_pkg_version_query) %}
1317
{% if not result %}

elementary/monitor/dbt_project/macros/get_test_last_invocation.sql

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,15 +8,15 @@
88
),
99

1010
test_invocation as (
11-
select distinct invocation_id, detected_at
11+
select {% if target.type in ('fabric', 'sqlserver') %}top 1{% endif %} distinct invocation_id, detected_at
1212
from elementary_test_results
1313
{% if invocation_id %}
1414
where invocation_id = {{ "'" ~ invocation_id ~ "'" }}
1515
{% elif invocation_max_time %}
1616
where detected_at < {{ "'" ~ invocation_max_time ~ "'" }}
1717
{% endif %}
1818
order by detected_at desc
19-
limit 1
19+
{% if target.type not in ('fabric', 'sqlserver') %}limit 1{% endif %}
2020
)
2121

2222
{% if invocations_relation %}

elementary/monitor/dbt_project/macros/test_conn.sql

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,11 @@
66
{% set elementary_database, elementary_schema = elementary.get_package_database_and_schema() %}
77
{% set elementary_model_relation = api.Relation.create(elementary_database, elementary_schema, "dbt_models") %}
88
{% set query %}
9+
{% if target.type in ('fabric', 'sqlserver') %}
10+
select top 10 * from {{ elementary_model_relation }}
11+
{% else %}
912
select * from {{ elementary_model_relation }} limit 10
13+
{% endif %}
1014
{% endset %}
1115
{% do elementary.run_query(query) %}
1216
{% endmacro %}

0 commit comments

Comments
 (0)