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

Reply via email to