We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1dc8447 commit a30b97fCopy full SHA for a30b97f
sdks/python/apache_beam/transforms/sideinputs.py
@@ -60,8 +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(),
64
- window=source_window)))[-1]
+ window.WindowFn.AssignContext(
+ source_window.max_timestamp(), window=source_window)))[-1]
65
66
return map_via_end
67
0 commit comments