damccorm commented on code in PR #41135:
URL: https://github.com/apache/beam/pull/41135#discussion_r4517884681
##########
sdks/python/apache_beam/transforms/window.py:
##########
@@ -255,6 +255,13 @@ class IntervalWindow(windowed_value._IntervalWindowBase,
BoundedWindow):
start: Start of window as seconds since Unix epoch.
end: End of window as seconds since Unix epoch.
"""
+ @classmethod
+ def from_micros(cls, start_micros: int, end_micros: int) -> 'IntervalWindow':
+ w = cls(None, None)
+ w._start_micros = start_micros
+ w._end_micros = end_micros
Review Comment:
Fixed in 677c956bef0: `IntervalWindow.from_micros` now catches
`OverflowError` and falls back to `cls(Timestamp(micros=start_micros),
Timestamp(micros=end_micros))`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
