You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ch...@apache.org on 2017/06/20 20:33:11 UTC
[1/2] beam git commit: Fix dataflow runner test to call pipeline.run
instead of runner.run
Repository: beam
Updated Branches:
refs/heads/master 59598d8f4 -> f51fdd960
Fix dataflow runner test to call pipeline.run instead of runner.run
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a0523b2d
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a0523b2d
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a0523b2d
Branch: refs/heads/master
Commit: a0523b2dab617d6aee59708a8d8959f42049fce9
Parents: 59598d8
Author: Vikas Kedigehalli <vi...@google.com>
Authored: Mon Jun 19 11:24:14 2017 -0700
Committer: chamikara@google.com <ch...@google.com>
Committed: Tue Jun 20 13:32:01 2017 -0700
----------------------------------------------------------------------
.../python/apache_beam/runners/dataflow/dataflow_runner_test.py | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/a0523b2d/sdks/python/apache_beam/runners/dataflow/dataflow_runner_test.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/runners/dataflow/dataflow_runner_test.py b/sdks/python/apache_beam/runners/dataflow/dataflow_runner_test.py
index 6cc5814..a9b8fdb 100644
--- a/sdks/python/apache_beam/runners/dataflow/dataflow_runner_test.py
+++ b/sdks/python/apache_beam/runners/dataflow/dataflow_runner_test.py
@@ -116,10 +116,7 @@ class DataflowRunnerTest(unittest.TestCase):
self.default_properties.append("--streaming")
p = Pipeline(remote_runner, PipelineOptions(self.default_properties))
p | ptransform.Create([1]) # pylint: disable=expression-not-assigned
- remote_runner.job = apiclient.Job(p._options)
- # Performing configured PTransform overrides here.
- p.replace_all(DataflowRunner._PTRANSFORM_OVERRIDES)
- super(DataflowRunner, remote_runner).run(p)
+ p.run()
job_dict = json.loads(str(remote_runner.job))
self.assertEqual(len(job_dict[u'steps']), 2)
[2/2] beam git commit: This closes #3393
Posted by ch...@apache.org.
This closes #3393
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f51fdd96
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f51fdd96
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f51fdd96
Branch: refs/heads/master
Commit: f51fdd960cbfbb9ab2b2870606bd0e221d4beceb
Parents: 59598d8 a0523b2
Author: chamikara@google.com <ch...@google.com>
Authored: Tue Jun 20 13:32:49 2017 -0700
Committer: chamikara@google.com <ch...@google.com>
Committed: Tue Jun 20 13:32:49 2017 -0700
----------------------------------------------------------------------
.../python/apache_beam/runners/dataflow/dataflow_runner_test.py | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
----------------------------------------------------------------------