[beam] branch aaltay-patch-1 created (now 781ff5b)

[al...@apache.org]

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

altay pushed a change to branch aaltay-patch-1
in repository https://gitbox.apache.org/repos/asf/beam.git.


      at 781ff5b  Log job id similar to Java and Go

This branch includes the following new commits:

     new 781ff5b  Log job id similar to Java and Go

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[beam] 01/01: Log job id similar to Java and Go

[al...@apache.org]

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

altay pushed a commit to branch aaltay-patch-1
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 781ff5b063316429f43ce57fabd468b6a6866073
Author: Ahmet Altay <aa...@gmail.com>
AuthorDate: Fri Apr 17 18:06:28 2020 -0700

    Log job id similar to Java and Go
    
    Still keeping the old log "Create job with id" in order to not breaking existing users. (Users literally parse this log to get job id.)
    
    Java and Go usage: https://github.com/apache/beam/search?q=%22Submitted+job%3A%22&unscoped_q=%22Submitted+job%3A%22
---
 sdks/python/apache_beam/runners/dataflow/internal/apiclient.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py b/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py
index 73b20bf..f79fb0b 100644
--- a/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py
+++ b/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py
@@ -736,6 +736,7 @@ class DataflowApplicationClient(object):
     _LOGGER.info('Create job: %s', response)
     # The response is a Job proto with the id for the new job.
     _LOGGER.info('Created job with id: [%s]', response.id)
+    _LOGGER.info('Submitted job: %s', response.id)
     _LOGGER.info(
         'To access the Dataflow monitoring console, please navigate to '
         'https://console.cloud.google.com/dataflow/jobs/%s/%s?project=%s',