You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2017/01/24 21:48:32 UTC
[1/2] beam git commit: Fix case where side inputs may be an iterable
rather than a list.
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 <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:
[2/2] beam git commit: Closes #1832
Posted by ro...@apache.org.
Closes #1832
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f9831236
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f9831236
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f9831236
Branch: refs/heads/python-sdk
Commit: f9831236c4a94af35a0a40a649323b578a3d92e4
Parents: d0dc1f3 9052366
Author: Robert Bradshaw <ro...@gmail.com>
Authored: Tue Jan 24 13:48:12 2017 -0800
Committer: Robert Bradshaw <ro...@gmail.com>
Committed: Tue Jan 24 13:48:12 2017 -0800
----------------------------------------------------------------------
sdks/python/apache_beam/runners/common.py | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------