This is an automated email from the ASF dual-hosted git repository. damccorm pushed a commit to branch users/damccorm/fixSampling in repository https://gitbox.apache.org/repos/asf/beam.git
commit a76adea9e3b408893cdd7d02301a001e559a54e0 Author: Danny McCormick <[email protected]> AuthorDate: Mon Nov 11 09:54:43 2024 -0500 Fix exception sampling logic --- sdks/python/apache_beam/runners/common.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/runners/common.py b/sdks/python/apache_beam/runners/common.py index 8a4f26c18e8..14aff44e6be 100644 --- a/sdks/python/apache_beam/runners/common.py +++ b/sdks/python/apache_beam/runners/common.py @@ -1608,7 +1608,7 @@ class DoFnRunner: _, _, tb = exc_info new_exn = new_exn.with_traceback(tb) - self._maybe_sample_exception(exc_info, windowed_value) + self._maybe_sample_exception(new_exn, windowed_value) _LOGGER.exception(new_exn) raise new_exn
