From 55015490aeea3e924ae2e924c2dd25f1eeaad2c5 Mon Sep 17 00:00:00 2001 From: Michelle Ark Date: Tue, 24 Sep 2024 21:37:07 +0100 Subject: [PATCH] add begin config + create date_day --- .../adapter/incremental_strategies/test_microbatch.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/tests/functional/adapter/incremental_strategies/test_microbatch.py b/tests/functional/adapter/incremental_strategies/test_microbatch.py index 6974d6b9b..3cc366142 100644 --- a/tests/functional/adapter/incremental_strategies/test_microbatch.py +++ b/tests/functional/adapter/incremental_strategies/test_microbatch.py @@ -6,8 +6,9 @@ # No requirement for a unique_id for spark microbatch! _microbatch_model_no_unique_id_sql = """ -{{ config(materialized='incremental', incremental_strategy='microbatch', event_time='event_time', batch_size='day') }} -select * from {{ ref('input_model') }} +{{ config(materialized='incremental', incremental_strategy='microbatch', event_time='event_time', batch_size='day', begin=modules.datetime.datetime(2020, 1, 1, 0, 0, 0)) }} +select *, cast(event_time as date) as date_day +from {{ ref('input_model') }} """