dbt-data-reliability/macros/utils/cross_db_utils/current_timestamp.sql at e6072fa92eb2de1b0f3bfe273d17a4663c53c61b · elementary-data/dbt-data-reliability · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
{% macro edr_current_timestamp() -%}
    {{ adapter.dispatch("edr_current_timestamp", "elementary")() }}
{%- endmacro %}

{% macro default__edr_current_timestamp() -%}
    {% set macro = dbt.current_timestamp_backcompat or dbt_utils.current_timestamp %}
    {% if not macro %}
        {{
            exceptions.raise_compiler_error(
                "Did not find a `current_timestamp` macro."
            )
        }}
    {% endif %}
    {{ return(macro()) }}
{%- endmacro %}

{% macro databricks__edr_current_timestamp() -%}
    {% set macro = dbt.current_timestamp_backcompat or dbt_utils.current_timestamp %}
    {% if not macro %}
        {{
            exceptions.raise_compiler_error(
                "Did not find a `current_timestamp` macro."
            )
        }}
    {% endif %}
    {{ return(macro()) }}
{%- endmacro %}

{% macro spark__edr_current_timestamp() %}
    cast(current_timestamp() as timestamp)
{% endmacro %}

{% macro clickhouse__edr_current_timestamp() %} now() {% endmacro %}

{% macro edr_current_timestamp_in_utc() -%}
    {{ adapter.dispatch("edr_current_timestamp_in_utc", "elementary")() }}
{%- endmacro %}

{% macro default__edr_current_timestamp_in_utc() -%}
    {% set macro = (
        dbt.current_timestamp_in_utc_backcompat
        or dbt_utils.current_timestamp_in_utc
    ) %}
    {% if not macro %}
        {{
            exceptions.raise_compiler_error(
                "Did not find a `current_timestamp_in_utc` macro."
            )
        }}
    {% endif %}
    {{ return(macro()) }}
{%- endmacro %}

{% macro databricks__edr_current_timestamp_in_utc() -%}
    {% set macro = (
        dbt.current_timestamp_in_utc_backcompat
        or dbt_utils.current_timestamp_in_utc
    ) %}
    {% if not macro %}
        {{
            exceptions.raise_compiler_error(
                "Did not find a `current_timestamp_in_utc` macro."
            )
        }}
    {% endif %}
    {{ return(macro()) }}
{%- endmacro %}

{% macro spark__edr_current_timestamp_in_utc() %}
    cast(unix_timestamp() as timestamp)
{% endmacro %}

{% macro clickhouse__edr_current_timestamp_in_utc() %} now('UTC') {% endmacro %}

{% macro athena__edr_current_timestamp() -%} current_timestamp {%- endmacro -%}

{% macro athena__edr_current_timestamp_in_utc() -%}
    cast(current_timestamp at time zone 'utc' as timestamp)
{%- endmacro -%}

{% macro trino__edr_current_timestamp() -%} current_timestamp(6) {%- endmacro -%}

{% macro trino__edr_current_timestamp_in_utc() -%}
    cast(current_timestamp at time zone 'UTC' as timestamp(6))
{%- endmacro -%}

{% macro fabric__edr_current_timestamp() -%}
    cast(getdate() as datetime2(6))
{%- endmacro -%}

{% macro fabric__edr_current_timestamp_in_utc() -%}
    cast(sysutcdatetime() as datetime2(6))
{%- endmacro -%}

{% macro fabricspark__edr_current_timestamp() %}
    {{ return(elementary.spark__edr_current_timestamp()) }}
{% endmacro %}

{% macro fabricspark__edr_current_timestamp_in_utc() %}
    {{ return(elementary.spark__edr_current_timestamp_in_utc()) }}
{% endmacro %}

{% macro dremio__edr_current_timestamp() -%} current_timestamp() {%- endmacro -%}

{% macro dremio__edr_current_timestamp_in_utc() -%}
    -- Dremio CURRENT_TIMESTAMP() is always in UTC
    current_timestamp()
{%- endmacro -%}