Skip to content

Commit df4693f

Browse files
committed
pr comments
1 parent 60fa3db commit df4693f

1 file changed

Lines changed: 6 additions & 2 deletions

File tree

elementary/monitor/dbt_project/macros/get_result_rows_agate.sql

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,10 +26,14 @@
2626
elementary_test_results_id,
2727
result_row
2828
from {{ ref("elementary", "test_result_rows") }}
29-
where detected_at >= {{ elementary.edr_timeadd('day', -1 * days_back, elementary.edr_current_timestamp()) }}
29+
where detected_at > {{ elementary.edr_timeadd('day', -1 * days_back, elementary.edr_current_timestamp()) }}
3030
{% if valid_ids_query %}
3131
and elementary_test_results_id in ({{ valid_ids_query }})
3232
{% endif %}
3333
{% endset %}
34-
{% do return(elementary.run_query(query).group_by("elementary_test_results_id")) %}
34+
{% set res = elementary.run_query(query) %}
35+
{% if not res %}
36+
{% do return({}) %}
37+
{% endif %}
38+
{% do return(res.group_by("elementary_test_results_id")) %}
3539
{% endmacro %}

0 commit comments

Comments
 (0)