[beam] branch master updated: Match catch clause in the codepath that reports the error to the worker to a clause that marks the bundle as failed. (#26777)

[tvalentyn]

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

tvalentyn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 81fbedb6cc9 Match catch clause in the codepath that reports the error 
to the worker to a clause that marks the bundle as failed. (#26777)
81fbedb6cc9 is described below

commit 81fbedb6cc92fbc255611fa6be18dc038cd251ca
Author: tvalentyn <tvalen...@users.noreply.github.com>
AuthorDate: Thu May 18 17:11:53 2023 -0700

    Match catch clause in the codepath that reports the error to the worker to 
a clause that marks the bundle as failed. (#26777)
---
 sdks/python/apache_beam/runners/worker/sdk_worker.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/sdks/python/apache_beam/runners/worker/sdk_worker.py 
b/sdks/python/apache_beam/runners/worker/sdk_worker.py
index 88beabd33ab..f7da86234d5 100644
--- a/sdks/python/apache_beam/runners/worker/sdk_worker.py
+++ b/sdks/python/apache_beam/runners/worker/sdk_worker.py
@@ -293,7 +293,7 @@ class SdkHarness(object):
     with statesampler.instruction_id(request.instruction_id):
       try:
         response = task()
-      except Exception:  # pylint: disable=broad-except
+      except:  # pylint: disable=bare-except
         traceback_string = traceback.format_exc()
         print(traceback_string, file=sys.stderr)
         _LOGGER.error(
@@ -680,7 +680,7 @@ class SdkWorker(object):
       if not requests_finalization:
         self.bundle_processor_cache.release(instruction_id)
       return response
-    except:  # pylint: disable=broad-except
+    except:  # pylint: disable=bare-except
       # Don't re-use bundle processors on failure.
       self.bundle_processor_cache.discard(instruction_id)
       raise