Align names with those produced by the dataflow runner harness. These will be unused once the runner harness produces the correct transform payloads.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ec192d15 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ec192d15 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ec192d15 Branch: refs/heads/master Commit: ec192d15d3e83d6fe2127619c8bbd69e83277918 Parents: a3a7807 Author: Robert Bradshaw <rober...@google.com> Authored: Wed Oct 4 13:57:01 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 | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/ec192d15/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 f44490b..05787e1 100644 --- a/sdks/python/apache_beam/runners/worker/bundle_processor.py +++ b/sdks/python/apache_beam/runners/worker/bundle_processor.py @@ -58,8 +58,8 @@ IDENTITY_DOFN_URN = 'urn:org.apache.beam:dofn:identity:0.1' PYTHON_ITERABLE_VIEWFN_URN = 'urn:org.apache.beam:viewfn:iterable:python:0.1' PYTHON_CODER_URN = 'urn:org.apache.beam:coder:python:0.1' # TODO(vikasrk): Fix this once runner sends appropriate python urns. -PYTHON_DOFN_URN = 'urn:org.apache.beam:dofn:java:0.1' -PYTHON_SOURCE_URN = 'urn:org.apache.beam:source:java:0.1' +OLD_DATAFLOW_RUNNER_HARNESS_PARDO_URN = 'urn:beam:dofn:javasdk:0.1' +OLD_DATAFLOW_RUNNER_HARNESS_READ_URN = 'urn:org.apache.beam:source:java:0.1' def side_input_tag(transform_id, tag): @@ -358,7 +358,7 @@ def create(factory, transform_id, transform_proto, grpc_port, consumers): data_channel=factory.data_channel_factory.create_data_channel(grpc_port)) -@BeamTransformFactory.register_urn(PYTHON_SOURCE_URN, None) +@BeamTransformFactory.register_urn(OLD_DATAFLOW_RUNNER_HARNESS_READ_URN, None) def create(factory, transform_id, transform_proto, parameter, consumers): # The Dataflow runner harness strips the base64 encoding. source = pickler.loads(base64.b64encode(parameter)) @@ -393,7 +393,7 @@ def create(factory, transform_id, transform_proto, parameter, consumers): consumers) -@BeamTransformFactory.register_urn(PYTHON_DOFN_URN, None) +@BeamTransformFactory.register_urn(OLD_DATAFLOW_RUNNER_HARNESS_PARDO_URN, None) def create(factory, transform_id, transform_proto, parameter, consumers): dofn_data = pickler.loads(parameter) if len(dofn_data) == 2:
