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(