beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rober...@apache.org
Subject [1/2] beam git commit: Don't log full exception traceback in direct runner.
Date Tue, 09 May 2017 05:59:59 GMT
Repository: beam
Updated Branches:
  refs/heads/master 3a09ed575 -> 9241fc69d


Don't log full exception traceback in direct runner.

It will be logged later if not caught.

This reduces duplication for failing tests, and noise for tests
expecting failure.


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/70680b5d
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/70680b5d
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/70680b5d

Branch: refs/heads/master
Commit: 70680b5d830ed3518f417824068d1817c304174b
Parents: 3a09ed5
Author: Robert Bradshaw <robertwb@gmail.com>
Authored: Mon May 8 16:06:30 2017 -0700
Committer: Robert Bradshaw <robertwb@gmail.com>
Committed: Mon May 8 22:59:42 2017 -0700

----------------------------------------------------------------------
 sdks/python/apache_beam/runners/direct/executor.py | 2 --
 1 file changed, 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/beam/blob/70680b5d/sdks/python/apache_beam/runners/direct/executor.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/runners/direct/executor.py b/sdks/python/apache_beam/runners/direct/executor.py
index 53aa3d0..0aa1aec 100644
--- a/sdks/python/apache_beam/runners/direct/executor.py
+++ b/sdks/python/apache_beam/runners/direct/executor.py
@@ -24,7 +24,6 @@ import logging
 import Queue
 import sys
 import threading
-import traceback
 from weakref import WeakValueDictionary
 
 from apache_beam.metrics.execution import MetricsContainer
@@ -308,7 +307,6 @@ class TransformExecutor(ExecutorService.CallableTask):
       self._completion_callback.handle_result(self._input_bundle, result)
       return result
     except Exception as e:  # pylint: disable=broad-except
-      logging.warning('Task failed: %s', traceback.format_exc(), exc_info=True)
       self._completion_callback.handle_exception(e)
     finally:
       self._evaluation_context.metrics().commit_physical(


Mime
View raw message