You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2016/12/05 21:01:34 UTC
[1/2] incubator-beam git commit: Add missing job parameter to the
submit_job_description.
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk f7118c8a5 -> d59bccd82
Add missing job parameter to the submit_job_description.
Tested post commit test locally.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f1b83f7e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f1b83f7e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/f1b83f7e
Branch: refs/heads/python-sdk
Commit: f1b83f7e82b56cd36bffbcdd5cc8ab319bf1e9d3
Parents: f7118c8
Author: Ahmet Altay <al...@google.com>
Authored: Mon Dec 5 12:29:45 2016 -0800
Committer: Ahmet Altay <al...@google.com>
Committed: Mon Dec 5 12:29:45 2016 -0800
----------------------------------------------------------------------
sdks/python/apache_beam/internal/apiclient.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/f1b83f7e/sdks/python/apache_beam/internal/apiclient.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/internal/apiclient.py b/sdks/python/apache_beam/internal/apiclient.py
index a894557..c5f5f70 100644
--- a/sdks/python/apache_beam/internal/apiclient.py
+++ b/sdks/python/apache_beam/internal/apiclient.py
@@ -412,7 +412,7 @@ class DataflowApplicationClient(object):
self.stage_file(gcs_or_local_path, file_name, StringIO(job.json()))
if not template_location:
- return self.submit_job_description()
+ return self.submit_job_description(job)
else:
return None
@@ -426,7 +426,7 @@ class DataflowApplicationClient(object):
# TODO(silviuc): Remove the debug logging eventually.
logging.info('JOB: %s', job)
- def submit_job_description(self):
+ def submit_job_description(self, job):
"""Creates and excutes a job request."""
request = dataflow.DataflowProjectsJobsCreateRequest()
request.projectId = self.google_cloud_options.project
[2/2] incubator-beam git commit: Closes #1509
Posted by ro...@apache.org.
Closes #1509
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d59bccd8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d59bccd8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/d59bccd8
Branch: refs/heads/python-sdk
Commit: d59bccd82461d340613a16ab41db2a4cc6e4200b
Parents: f7118c8 f1b83f7
Author: Robert Bradshaw <ro...@gmail.com>
Authored: Mon Dec 5 13:01:19 2016 -0800
Committer: Robert Bradshaw <ro...@gmail.com>
Committed: Mon Dec 5 13:01:19 2016 -0800
----------------------------------------------------------------------
sdks/python/apache_beam/internal/apiclient.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------