From 8e03369a3a7403a7ab9c56779e8c253b7dc6e36a Mon Sep 17 00:00:00 2001 From: riteshghorse Date: Tue, 10 Oct 2023 12:53:01 -0400 Subject: [PATCH] fix lint --- sdks/python/apache_beam/runners/worker/bundle_processor.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/runners/worker/bundle_processor.py b/sdks/python/apache_beam/runners/worker/bundle_processor.py index c7fcb9587455..7ff0ad258bc2 100644 --- a/sdks/python/apache_beam/runners/worker/bundle_processor.py +++ b/sdks/python/apache_beam/runners/worker/bundle_processor.py @@ -233,7 +233,7 @@ def process_encoded(self, encoded_windowed_values): except Exception as exn: raise ValueError( "Error decoding input stream with coder " + - self.windowed_coder) from exn + str(self.windowed_coder)) from exn self.output(decoded_value) def monitoring_infos(self, transform_id, tag_to_pcollection_id):