From a76adea9e3b408893cdd7d02301a001e559a54e0 Mon Sep 17 00:00:00 2001 From: Danny McCormick Date: Mon, 11 Nov 2024 09:54:43 -0500 Subject: [PATCH] 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 8a4f26c18e88..14aff44e6be0 100644 --- a/sdks/python/apache_beam/runners/common.py +++ b/sdks/python/apache_beam/runners/common.py @@ -1608,7 +1608,7 @@ def _reraise_augmented(self, exn, windowed_value=None): _, _, 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