Update resolve_event_time_filter to use new batch_context

dbt-labs · Nov 27, 2024 · f3748a8 · f3748a8
1 parent ee0c1d7
commit f3748a8
Showing 1 changed file with 3 additions and 2 deletions.
diff --git 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(