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
