(beam) branch users/damccorm/fixSampling created (now a76adea9e3b)

[da...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

damccorm pushed a change to branch users/damccorm/fixSampling
in repository https://gitbox.apache.org/repos/asf/beam.git


      at a76adea9e3b Fix exception sampling logic

This branch includes the following new commits:

     new a76adea9e3b Fix exception sampling logic

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

(beam) 01/01: Fix exception sampling logic

[da...@apache.org]

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 <da...@google.com>
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