diff --git a/transform/mattermost-analytics/models/staging/mm_telemetry_prod/base/base_events.sql b/transform/mattermost-analytics/models/staging/mm_telemetry_prod/base/base_events.sql index bc6ecec2ed..e3473df6c8 100644 --- a/transform/mattermost-analytics/models/staging/mm_telemetry_prod/base/base_events.sql +++ b/transform/mattermost-analytics/models/staging/mm_telemetry_prod/base/base_events.sql @@ -9,6 +9,8 @@ from {{ source('mm_telemetry_prod', 'event') }} where {% if is_incremental() %} - -- Hack to disable incremental for now + -- Hack to run only once false +{% else %} + received_at < current_date() {% endif %} diff --git a/transform/mattermost-analytics/models/staging/mm_telemetry_prod/base/base_events_delta.sql b/transform/mattermost-analytics/models/staging/mm_telemetry_prod/base/base_events_delta.sql index 0531563422..343aa64f82 100644 --- a/transform/mattermost-analytics/models/staging/mm_telemetry_prod/base/base_events_delta.sql +++ b/transform/mattermost-analytics/models/staging/mm_telemetry_prod/base/base_events_delta.sql @@ -10,4 +10,4 @@ from {{ source('mm_telemetry_prod', 'event') }} where received_at >= (select max(received_at) FROM {{ ref('base_events') }}) -qualify 1 = row_number() over(partition by id order by received_at desc) \ No newline at end of file +qualify 1 = row_number() over (partition by id order by received_at desc) \ No newline at end of file