Update MicrobatchBuilder.build_end_time to use ceiling_timestamp

dbt-labs · Oct 18, 2024 · 3e2b3e2 · 3e2b3e2
1 parent bad3e0b
commit 3e2b3e2
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/core/dbt/materializations/incremental/microbatch.py b/core/dbt/materializations/incremental/microbatch.py
@@ -40,7 +40,8 @@ def __init__(
 
  def build_end_time(self):
  """Defaults the end_time to the current time in UTC unless a non `None` event_time_end was provided"""
- return self.event_time_end or self.default_end_time
+ end_time = self.event_time_end or self.default_end_time
+ return MicrobatchBuilder.ceiling_timestamp(end_time, self.model.config.batch_size)
 
  def build_start_time(self, checkpoint: Optional[datetime]):
  """Create a start time based off the passed in checkpoint.