Skip to content

Commit

Permalink
Update resolve_event_time_filter to use new batch_context
Browse files Browse the repository at this point in the history
  • Loading branch information
QMalcolm committed Nov 27, 2024
1 parent 345e474 commit c27c494
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions core/dbt/context/providers.py
Original file line number Diff line number Diff line change
Expand Up @@ -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(
Expand Down

0 comments on commit c27c494

Please sign in to comment.