We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a57872f commit 1dc8447Copy full SHA for 1dc8447
sdks/python/apache_beam/transforms/sideinputs.py
@@ -60,7 +60,8 @@ def default_window_mapping_fn(
60
def map_via_end(source_window: window.BoundedWindow) -> window.BoundedWindow:
61
return list(
62
target_window_fn.assign(
63
- window.WindowFn.AssignContext(source_window.max_timestamp())))[-1]
+ window.WindowFn.AssignContext(source_window.max_timestamp(),
64
+ window=source_window)))[-1]
65
66
return map_via_end
67
0 commit comments