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/d91ebd9f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d91ebd9f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d91ebd9f Branch: refs/heads/master Commit: d91ebd9f5fa3cf5c250f02096c27c21354dce859 Parents: ec192d1 Author: Robert Bradshaw <rober...@google.com> Authored: Wed Oct 4 17:33:07 2017 -0700 Committer: Robert Bradshaw <rober...@gmail.com> Committed: Fri Oct 13 14:41:04 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/d91ebd9f/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 05787e1..a54e6b1 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)
