Repository: beam Updated Branches: refs/heads/release-2.2.0 c2e030639 -> 6db1db7b4
Fix from any -> bytes transition. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9b063eb3 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9b063eb3 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9b063eb3 Branch: refs/heads/release-2.2.0 Commit: 9b063eb3b056c4f3d199c0c24c5f2857d84247fa Parents: a375b2e Author: Robert Bradshaw <[email protected]> Authored: Wed Oct 4 17:33:07 2017 -0700 Committer: Ahmet Altay <[email protected]> Committed: Mon Oct 30 14:39:58 2017 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/runners/worker/bundle_processor.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/9b063eb3/sdks/python/apache_beam/runners/worker/bundle_processor.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/runners/worker/bundle_processor.py b/sdks/python/apache_beam/runners/worker/bundle_processor.py index 69e4ade..fb8befb 100644 --- a/sdks/python/apache_beam/runners/worker/bundle_processor.py +++ b/sdks/python/apache_beam/runners/worker/bundle_processor.py @@ -401,7 +401,7 @@ def create(factory, transform_id, transform_proto, parameter, consumers): serialized_fn, side_input_data = dofn_data else: # No side input data. - serialized_fn, side_input_data = parameter.value, [] + serialized_fn, side_input_data = parameter, [] return _create_pardo_operation( factory, transform_id, transform_proto, consumers, serialized_fn, side_input_data)
