[15/50] [abbrv] beam git commit: Fix case where side inputs may be an iterable rather than a list.

[da...@apache.org]

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/master
Commit: 9052366f0474b19c35b2838e6790e3333750e09e
Parents: d0dc1f3
Author: Robert Bradshaw <ro...@gmail.com>
Authored: Tue Jan 24 11:57:20 2017 -0800
Committer: Robert Bradshaw <ro...@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: