beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From al...@apache.org
Subject [1/3] beam git commit: Fix from any -> bytes transition.
Date Mon, 30 Oct 2017 21:40:22 GMT
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 <robertwb@google.com>
Authored: Wed Oct 4 17:33:07 2017 -0700
Committer: Ahmet Altay <altay@google.com>
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)


Mime
View raw message