Skip to content

Commit 87db356

Browse files
authored
Add "return []" to PGBK to silence warning (#36535)
1 parent 34a6f54 commit 87db356

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

sdks/python/apache_beam/transforms/combiners.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1067,6 +1067,7 @@ def process(self, element, window=core.DoFn.WindowParam, **side_inputs):
10671067
self._cache[k, window], vi, *side_input_args, **side_input_kwargs)
10681068
self._cached_windowed_side_inputs[window] = (
10691069
side_input_args, side_input_kwargs)
1070+
return [] # to prevent DoFn-no-iterator warning
10701071

10711072
def finish_bundle(self):
10721073
for (k, w), va in self._cache.items():

0 commit comments

Comments
 (0)