You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2017/04/05 00:04:08 UTC
[1/2] beam git commit: Do not have empty side input names
Repository: beam
Updated Branches:
refs/heads/master 5eb78ae8a -> fcf3b5619
Do not have empty side input names
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0fd9622e
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0fd9622e
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0fd9622e
Branch: refs/heads/master
Commit: 0fd9622e1e449a2bd7149d0888660c6a3eca8968
Parents: 5eb78ae
Author: Ahmet Altay <al...@google.com>
Authored: Tue Apr 4 16:25:45 2017 -0700
Committer: Ahmet Altay <al...@google.com>
Committed: Tue Apr 4 16:25:45 2017 -0700
----------------------------------------------------------------------
sdks/python/apache_beam/runners/dataflow/dataflow_runner.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/0fd9622e/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
index fe9f8c0..f0600bc 100644
--- a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
+++ b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
@@ -391,7 +391,8 @@ class DataflowRunner(PipelineRunner):
# Now create the step for the ParDo transform being handled.
step = self._add_step(
TransformNames.DO,
- transform_node.full_label + '/Do' if transform_node.side_inputs else '',
+ transform_node.full_label + (
+ '/Do' if transform_node.side_inputs else ''),
transform_node,
transform_node.transform.side_output_tags)
fn_data = self._pardo_fn_data(transform_node, lookup_label)
[2/2] beam git commit: This closes #2429
Posted by al...@apache.org.
This closes #2429
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fcf3b561
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fcf3b561
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/fcf3b561
Branch: refs/heads/master
Commit: fcf3b5619501d5846026a35aee683ac0c4f925a4
Parents: 5eb78ae 0fd9622
Author: Ahmet Altay <al...@google.com>
Authored: Tue Apr 4 17:03:59 2017 -0700
Committer: Ahmet Altay <al...@google.com>
Committed: Tue Apr 4 17:03:59 2017 -0700
----------------------------------------------------------------------
sdks/python/apache_beam/runners/dataflow/dataflow_runner.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------