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 <[email protected]> Authored: Mon May 8 16:06:30 2017 -0700 Committer: Robert Bradshaw <[email protected]> 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(
