Repository: beam Updated Branches: refs/heads/python-sdk d0dc1f375 -> f9831236c
Fix case where side inputs may be an iterable rather than a list. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9052366f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9052366f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9052366f Branch: refs/heads/python-sdk Commit: 9052366f0474b19c35b2838e6790e3333750e09e Parents: d0dc1f3 Author: Robert Bradshaw <rober...@gmail.com> Authored: Tue Jan 24 11:57:20 2017 -0800 Committer: Robert Bradshaw <rober...@gmail.com> Committed: Tue Jan 24 11:57:20 2017 -0800 ---------------------------------------------------------------------- sdks/python/apache_beam/runners/common.py | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/9052366f/sdks/python/apache_beam/runners/common.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/runners/common.py b/sdks/python/apache_beam/runners/common.py index 9c8fdfc..3741582 100644 --- a/sdks/python/apache_beam/runners/common.py +++ b/sdks/python/apache_beam/runners/common.py @@ -91,6 +91,9 @@ class DoFnRunner(Receiver): global_window = window.GlobalWindow() + # Need to support multiple iterations. + side_inputs = list(side_inputs) + if logging_context: self.logging_context = logging_context else: