From 58f6c7da05045694d045206a34d0147dc09bc903 Mon Sep 17 00:00:00 2001 From: Shunping Huang Date: Tue, 21 Oct 2025 09:45:50 -0400 Subject: [PATCH] Call now() once so start and end have exactly the same base timestamp. (#36574) --- sdks/python/apache_beam/transforms/periodicsequence.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/sdks/python/apache_beam/transforms/periodicsequence.py b/sdks/python/apache_beam/transforms/periodicsequence.py index 60225d43acb6..82b6fd0330c9 100644 --- a/sdks/python/apache_beam/transforms/periodicsequence.py +++ b/sdks/python/apache_beam/transforms/periodicsequence.py @@ -337,8 +337,7 @@ def expand(self, pbegin): if self.rebase == RebaseMode.REBASE_ALL: duration = Timestamp.of(self.stop_ts) - Timestamp.of(self.start_ts) impulse_element = pbegin | beam.Impulse() | beam.Map( - lambda _: - [Timestamp.now(), Timestamp.now() + duration, self.interval]) + lambda _: [now := Timestamp.now(), now + duration, self.interval]) elif self.rebase == RebaseMode.REBASE_START: impulse_element = pbegin | beam.Impulse() | beam.Map( lambda _: [Timestamp.now(), self.stop_ts, self.interval])