Repository: beam Updated Branches: refs/heads/master a2047acdb -> cf5450f8a
Change dataflow Job log from info to debug Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/06cf0b58 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/06cf0b58 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/06cf0b58 Branch: refs/heads/master Commit: 06cf0b58589344cc1f04c26991c94aaeba7823d0 Parents: a2047ac Author: Vikas Kedigehalli <[email protected]> Authored: Fri Apr 21 15:26:50 2017 -0700 Committer: Chamikara Jayalath <[email protected]> Committed: Fri Apr 21 16:20:29 2017 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/runners/dataflow/internal/apiclient.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/06cf0b58/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py b/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py index 8d44dff..24e1129 100644 --- a/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py +++ b/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py @@ -448,8 +448,7 @@ class DataflowApplicationClient(object): job.proto.environment = Environment( packages=resources, options=job.options, environment_version=self.environment_version).proto - # TODO(silviuc): Remove the debug logging eventually. - logging.info('JOB: %s', job) + logging.debug('JOB: %s', job) @retry.with_exponential_backoff(num_retries=3, initial_delay_secs=3) def get_job_metrics(self, job_id):
