[beam] 02/02: [BEAM-8348] set job_name in portable_runner.py job request

[ib...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

ibzib pushed a commit to branch job_name
in repository https://gitbox.apache.org/repos/asf/beam.git

commit fc8eacbd2afe350f4f6eaa018bbd557742d9dce4
Author: Kyle Weaver <kc...@google.com>
AuthorDate: Fri Oct 18 16:51:03 2019 +0200

    [BEAM-8348] set job_name in portable_runner.py job request
---
 sdks/python/apache_beam/runners/portability/portable_runner.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/sdks/python/apache_beam/runners/portability/portable_runner.py b/sdks/python/apache_beam/runners/portability/portable_runner.py
index 16c6eba..f017476 100644
--- a/sdks/python/apache_beam/runners/portability/portable_runner.py
+++ b/sdks/python/apache_beam/runners/portability/portable_runner.py
@@ -310,7 +310,8 @@ class PortableRunner(runner.PipelineRunner):
 
     prepare_response = job_service.Prepare(
         beam_job_api_pb2.PrepareJobRequest(
-            job_name='job', pipeline=proto_pipeline,
+            job_name=options.view_as(StandardOptions).job_name or 'job',
+            pipeline=proto_pipeline,
             pipeline_options=job_utils.dict_to_struct(p_options)),
         timeout=portable_options.job_server_timeout)
     if prepare_response.artifact_staging_endpoint.url: