Repository: incubator-beam Updated Branches: refs/heads/python-sdk 37f426faf -> d78b38d1d
Remove expensive per-element-step logging context. This is 3-4% of the total runtime. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f99aa77f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f99aa77f Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/f99aa77f Branch: refs/heads/python-sdk Commit: f99aa77f9acf5dbfdf762913a1f997d2c3658d3a Parents: 37f426f Author: Robert Bradshaw <rober...@google.com> Authored: Thu Jul 21 12:08:33 2016 -0700 Committer: Robert Bradshaw <rober...@google.com> Committed: Thu Jul 21 17:35:49 2016 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/runners/common.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/f99aa77f/sdks/python/apache_beam/runners/common.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/runners/common.py b/sdks/python/apache_beam/runners/common.py index ef28c63..134fb06 100644 --- a/sdks/python/apache_beam/runners/common.py +++ b/sdks/python/apache_beam/runners/common.py @@ -95,9 +95,8 @@ class DoFnRunner(object): def process(self, element): try: - with self.logger.PerThreadLoggingContext(step_name=self.step_name): - self.context.set_element(element) - self._process_outputs(element, self.dofn.process(self.context)) + self.context.set_element(element) + self._process_outputs(element, self.dofn.process(self.context)) except BaseException as exn: self.reraise_augmented(exn)
