From c27c494cfbec6ace1ffe3ac6cce175c5f2ddbad8 Mon Sep 17 00:00:00 2001 From: Quigley Malcolm Date: Wed, 27 Nov 2024 10:29:45 -0600 Subject: [PATCH] Update `resolve_event_time_filter` to use new `batch_context` --- core/dbt/context/providers.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/core/dbt/context/providers.py b/core/dbt/context/providers.py index 188ad5480b0..ca6a46c4f7a 100644 --- a/core/dbt/context/providers.py +++ b/core/dbt/context/providers.py @@ -244,9 +244,10 @@ def resolve_event_time_filter(self, target: ManifestNode) -> Optional[EventTimeF and self.model.config.materialized == "incremental" and self.model.config.incremental_strategy == "microbatch" and self.manifest.use_microbatch_batches(project_name=self.config.project_name) + and self.model.batch_context is not None ): - start = self.model.config.get("__dbt_internal_microbatch_event_time_start") - end = self.model.config.get("__dbt_internal_microbatch_event_time_end") + start = self.model.batch_context.event_time_start + end = self.model.batch_context.event_time_end if start is not None or end is not None: event_time_filter = EventTimeFilter(